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