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
All Methods Static Methods Instance Methods Concrete Methods 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
-
-
-
-
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)
-
-