public class MessageHub
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private boolean |
m_debug |
private IMessageSender |
m_messageSender |
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.
|
private boolean m_debug
private IMessageSender m_messageSender
public MessageHub(IMessageSender messageSender)
public void connect() throws java.io.IOException
org.testng.TestNGException
- if an exception occurred while establishing the connectionjava.io.IOException
public void shutDown()
public void sendMessage(IMessage message)
public IMessage receiveMessage()
public void setDebug(boolean debug)
public void initReceiver() throws java.net.SocketTimeoutException
java.net.SocketTimeoutException
public IMessageSender getMessageSender()