public class MessageHub extends Object
| Constructor and Description |
|---|
MessageHub(IMessageSender messageSender) |
| Modifier and Type | Method and Description |
|---|---|
void |
connect()
Starts the connection.
|
IMessageSender |
getMessageSender() |
void |
initReceiver() |
IMessage |
receiveMessage() |
void |
sendMessage(IMessage message) |
void |
setDebug(boolean debug) |
void |
shutDown()
Shutsdown the connection to the remote test listener.
|
public MessageHub(IMessageSender messageSender)
public void connect()
throws IOException
TestNGException - if an exception occurred while establishing the connectionIOExceptionpublic void shutDown()
public void sendMessage(IMessage message)
public IMessage receiveMessage()
public void setDebug(boolean debug)
public void initReceiver()
throws SocketTimeoutException
SocketTimeoutExceptionpublic IMessageSender getMessageSender()
Copyright © 2016. All Rights Reserved.