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 IMessageSender
IOException
public void initReceiver() throws SocketTimeoutException
IMessageSender
initReceiver
in interface IMessageSender
SocketTimeoutException
public void stopReceiver()
IMessageSender
stopReceiver
in interface IMessageSender
public void sendMessage(IMessage message) throws Exception
sendMessage
in interface IMessageSender
Exception
public IMessage receiveMessage() throws Exception
IMessageSender
receiveMessage
in interface IMessageSender
Exception
public void shutDown()
shutDown
in interface IMessageSender
public void sendAck()
sendAck
in interface IMessageSender
public void sendStop()
sendStop
in interface IMessageSender
Copyright © 2019. All rights reserved.