public class MessageInputStream extends InputStream implements MessageAppender
Constructor and Description |
---|
MessageInputStream(AnnotatedEventDriver driver) |
Modifier and Type | Method and Description |
---|---|
void |
appendMessage(ByteBuffer payload)
Append the payload to the message.
|
void |
close() |
void |
messageComplete()
Notification that message is to be considered complete.
|
int |
read() |
available, mark, markSupported, read, read, reset, skip
public MessageInputStream(AnnotatedEventDriver driver)
public void appendMessage(ByteBuffer payload) throws IOException
MessageAppender
appendMessage
in interface MessageAppender
payload
- the payload to append.IOException
- if unable to append the payloadpublic void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class InputStream
IOException
public void messageComplete()
MessageAppender
messageComplete
in interface MessageAppender
public int read() throws IOException
read
in class InputStream
IOException
Copyright © 1995-2012 Mort Bay Consulting. All Rights Reserved.