Package org.testng.remote.strprotocol

Class JsonMessageSender

java.lang.Object

org.testng.remote.strprotocol.BaseMessageSender

org.testng.remote.strprotocol.JsonMessageSender

All Implemented Interfaces:

IMessageSender

public class JsonMessageSender
extends BaseMessageSender

Field Summary

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

m_ackLock, m_clientSocket, m_inReader, m_inStream, m_outStream

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
(package private) IMessage	deserializeMessage(java.lang.String jsonMsg)
private static void	p(java.lang.String msg)
IMessage	receiveMessage()	Will return null or throw EOFException when the connection has been severed.
void	sendMessage(IMessage message)
(package private) void	writeMessage(com.google.gson.stream.JsonWriter writer, 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

Constructor Detail

JsonMessageSender

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

JsonMessageSender

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

Method Detail

sendMessage

public void sendMessage(IMessage message)
                 throws java.lang.Exception

Throws:

java.lang.Exception

writeMessage

void writeMessage(com.google.gson.stream.JsonWriter writer,
                  IMessage message)
           throws java.io.IOException

Throws:

java.io.IOException

receiveMessage

public IMessage receiveMessage()
                        throws java.lang.Exception

Description copied from interface: IMessageSender

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

Throws:

java.lang.Exception

deserializeMessage

IMessage deserializeMessage(java.lang.String jsonMsg)
                     throws java.io.IOException

Throws:

java.io.IOException

p

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