public interface MessageStreamWriter
| Modifier and Type | Method and Description |
|---|---|
boolean |
tryClose() |
void |
write(String topic,
Object msg) |
void |
writeByteAsInt(int byteToWrite) |
void |
writeBytes(byte[] bytes) |
void |
writeReply(int reqId,
String reqTopic,
Object replyMsg) |
void |
writeRequest(int reqId,
String reqTopic,
Object req) |
void |
writeSubscription(int msgType,
String subject,
Charset charset) |
void writeByteAsInt(int byteToWrite)
throws IOException
IOExceptionvoid write(String topic, Object msg) throws IOException
IOExceptionvoid writeRequest(int reqId,
String reqTopic,
Object req)
throws IOException
IOExceptionvoid writeBytes(byte[] bytes)
throws IOException
IOExceptionboolean tryClose()
void writeReply(int reqId,
String reqTopic,
Object replyMsg)
throws IOException
IOExceptionvoid writeSubscription(int msgType,
String subject,
Charset charset)
throws IOException
IOExceptionCopyright © 2016. All Rights Reserved.