public class StringMessageSender extends BaseMessageSender
Modifier and Type | Field and Description |
---|---|
private java.io.PrintWriter |
writer |
m_ackLock, m_clientSocket, m_inReader, m_inStream, m_outStream
Constructor and Description |
---|
StringMessageSender(java.lang.String host,
int port) |
StringMessageSender(java.lang.String host,
int port,
boolean ack) |
Modifier and Type | Method and Description |
---|---|
protected void |
handleThrowable(java.lang.Throwable cause) |
private static void |
p(java.lang.String msg) |
IMessage |
receiveMessage()
Will return null or throw EOFException when the connection has been severed.
|
private IMessage |
receiveMessage(java.lang.String message) |
void |
sendMessage(IMessage message) |
connect, initReceiver, sendAck, sendStop, shutDown, stopReceiver, waitForAck
public StringMessageSender(java.lang.String host, int port)
public StringMessageSender(java.lang.String host, int port, boolean ack)
public void sendMessage(IMessage message)
private static void p(java.lang.String msg)
public IMessage receiveMessage()
IMessageSender
protected void handleThrowable(java.lang.Throwable cause)
private IMessage receiveMessage(java.lang.String message)