public class JsonMessageSender extends BaseMessageSender
m_ackLock, m_clientSocket, m_inReader, m_inStream, m_outStream
Constructor and Description |
---|
JsonMessageSender(java.lang.String host,
int port) |
JsonMessageSender(java.lang.String host,
int port,
boolean ack) |
Modifier and Type | Method and Description |
---|---|
(package private) IMessage |
deserializeMessage(java.lang.String jsonMsg) |
private static void |
p(java.lang.String msg) |
IMessage |
receiveMessage()
Will return null or throw EOFException when the connection has been severed.
|
void |
sendMessage(IMessage message) |
(package private) void |
writeMessage(com.google.gson.stream.JsonWriter writer,
IMessage message) |
connect, initReceiver, sendAck, sendStop, shutDown, stopReceiver, waitForAck
public JsonMessageSender(java.lang.String host, int port)
public JsonMessageSender(java.lang.String host, int port, boolean ack)
public void sendMessage(IMessage message) throws java.lang.Exception
java.lang.Exception
void writeMessage(com.google.gson.stream.JsonWriter writer, IMessage message) throws java.io.IOException
java.io.IOException
public IMessage receiveMessage() throws java.lang.Exception
IMessageSender
java.lang.Exception
IMessage deserializeMessage(java.lang.String jsonMsg) throws java.io.IOException
java.io.IOException
private static void p(java.lang.String msg)