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 IMessageSenderjava.io.IOExceptionpublic void initReceiver()
throws java.net.SocketTimeoutException
IMessageSenderinitReceiver in interface IMessageSenderjava.net.SocketTimeoutExceptionpublic void stopReceiver()
IMessageSenderstopReceiver in interface IMessageSenderpublic void sendMessage(IMessage message) throws java.lang.Exception
sendMessage in interface IMessageSenderjava.lang.Exceptionpublic IMessage receiveMessage() throws java.lang.Exception
IMessageSenderreceiveMessage in interface IMessageSenderjava.lang.Exceptionpublic void shutDown()
shutDown in interface IMessageSenderpublic void sendAck()
sendAck in interface IMessageSenderpublic void sendStop()
sendStop in interface IMessageSender