Package org.testng.remote.strprotocol

Class StringMessageSender

java.lang.Object

org.testng.remote.strprotocol.BaseMessageSender

org.testng.remote.strprotocol.StringMessageSender

All Implemented Interfaces:

IMessageSender

public class StringMessageSender
extends BaseMessageSender

Field Summary

Fields

Modifier and Type	Field	Description
private java.io.PrintWriter	writer

Fields inherited from class org.testng.remote.strprotocol.BaseMessageSender

m_ackLock, m_clientSocket, m_inReader, m_inStream, m_outStream

Constructor Summary

Constructors

Constructor	Description
StringMessageSender(java.lang.String host, int port)
StringMessageSender(java.lang.String host, int port, boolean ack)

Method Summary

Modifier and Type	Method	Description
protected void	handleThrowable(java.lang.Throwable cause)
private static void	p(java.lang.String msg)
IMessage	receiveMessage()	Will return null or throw EOFException when the connection has been severed.
private IMessage	receiveMessage(java.lang.String message)
void	sendMessage(IMessage message)

Methods inherited from class org.testng.remote.strprotocol.BaseMessageSender

connect, initReceiver, sendAck, sendStop, shutDown, stopReceiver, waitForAck

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

writer

private java.io.PrintWriter writer

Constructor Detail

StringMessageSender

public StringMessageSender(java.lang.String host,
                           int port)

StringMessageSender

public StringMessageSender(java.lang.String host,
                           int port,
                           boolean ack)

Method Detail

sendMessage

public void sendMessage(IMessage message)

p

private static void p(java.lang.String msg)

receiveMessage

public IMessage receiveMessage()

Description copied from interface: IMessageSender

Will return null or throw EOFException when the connection has been severed.

handleThrowable

protected void handleThrowable(java.lang.Throwable cause)

receiveMessage

private IMessage receiveMessage(java.lang.String message)