public class StdoutMessageSender extends 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 IOException
connect in interface IMessageSenderIOExceptionpublic void initReceiver()
throws SocketTimeoutException
IMessageSenderinitReceiver in interface IMessageSenderSocketTimeoutExceptionpublic void stopReceiver()
IMessageSenderstopReceiver in interface IMessageSenderpublic void sendMessage(IMessage message) throws Exception
sendMessage in interface IMessageSenderExceptionpublic IMessage receiveMessage() throws Exception
IMessageSenderreceiveMessage in interface IMessageSenderExceptionpublic void shutDown()
shutDown in interface IMessageSenderpublic void sendAck()
sendAck in interface IMessageSenderpublic void sendStop()
sendStop in interface IMessageSenderCopyright © 2024. All rights reserved.