public class StdoutMessageSender extends java.lang.Object implements IMessageSender
Constructor and Description |
---|
StdoutMessageSender() |
Modifier and Type | Method and Description |
---|---|
void |
connect() |
void |
initReceiver()
Initialize the receiver.
|
IMessage |
receiveMessage()
Will return null or throw EOFException when the connection has been severed.
|
void |
sendAck() |
void |
sendMessage(IMessage message) |
void |
sendStop() |
void |
shutDown() |
void |
stopReceiver()
Stop the receiver.
|
public void connect() throws java.io.IOException
connect
in interface IMessageSender
java.io.IOException
public void initReceiver() throws java.net.SocketTimeoutException
IMessageSender
initReceiver
in interface IMessageSender
java.net.SocketTimeoutException
public void stopReceiver()
IMessageSender
stopReceiver
in interface IMessageSender
public void sendMessage(IMessage message) throws java.lang.Exception
sendMessage
in interface IMessageSender
java.lang.Exception
public IMessage receiveMessage() throws java.lang.Exception
IMessageSender
receiveMessage
in interface IMessageSender
java.lang.Exception
public void shutDown()
shutDown
in interface IMessageSender
public void sendAck()
sendAck
in interface IMessageSender
public void sendStop()
sendStop
in interface IMessageSender