public abstract class BaseMessageSender extends java.lang.Object implements IMessageSender
Modifier and Type | Class and Description |
---|---|
private class |
BaseMessageSender.ReaderThread
Reader thread that processes messages from the client.
|
Modifier and Type | Field and Description |
---|---|
private boolean |
m_ack |
protected java.lang.Object |
m_ackLock |
protected java.net.Socket |
m_clientSocket |
private java.lang.String |
m_host |
protected java.io.BufferedReader |
m_inReader
Used to receive ACK and STOP
|
protected java.io.InputStream |
m_inStream
Incoming message stream.
|
private java.lang.String |
m_latestAck |
protected java.io.OutputStream |
m_outStream
Outgoing message stream.
|
private java.io.PrintWriter |
m_outWriter
Used to send ACK and STOP
|
private int |
m_port |
private BaseMessageSender.ReaderThread |
m_readerThread |
private boolean |
m_requestStopReceiver |
private int |
m_serial |
private java.net.ServerSocket |
m_serverSocket |
Constructor and Description |
---|
BaseMessageSender(java.lang.String host,
int port,
boolean ack) |
Modifier and Type | Method and Description |
---|---|
private void |
closeQuietly(java.io.Closeable c) |
void |
connect()
Starts the connection.
|
void |
initReceiver()
Initialize the receiver.
|
private static void |
p(java.lang.String msg) |
void |
sendAck() |
private void |
sendAdminMessage(java.lang.String message) |
void |
sendStop() |
void |
shutDown() |
void |
stopReceiver()
Stop the receiver.
|
protected void |
waitForAck() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
receiveMessage, sendMessage
protected java.net.Socket m_clientSocket
private java.lang.String m_host
private int m_port
protected java.lang.Object m_ackLock
private boolean m_requestStopReceiver
private java.net.ServerSocket m_serverSocket
protected java.io.OutputStream m_outStream
private java.io.PrintWriter m_outWriter
protected volatile java.io.InputStream m_inStream
protected volatile java.io.BufferedReader m_inReader
private BaseMessageSender.ReaderThread m_readerThread
private boolean m_ack
private int m_serial
private java.lang.String m_latestAck
public BaseMessageSender(java.lang.String host, int port, boolean ack)
public void connect() throws java.io.IOException
connect
in interface IMessageSender
org.testng.TestNGException
- if an exception occurred while establishing the connectionjava.io.IOException
private void sendAdminMessage(java.lang.String message)
public void sendAck()
sendAck
in interface IMessageSender
public void sendStop()
sendStop
in interface IMessageSender
public void initReceiver() throws java.net.SocketTimeoutException
IMessageSender
initReceiver
in interface IMessageSender
java.net.SocketTimeoutException
public void stopReceiver()
IMessageSender
stopReceiver
in interface IMessageSender
public void shutDown()
shutDown
in interface IMessageSender
private void closeQuietly(java.io.Closeable c)
protected void waitForAck()
private static void p(java.lang.String msg)