net.sergeych.farcall

Class JsonConnector

java.lang.Object

net.sergeych.tools.JsonTool

net.sergeych.farcall.BasicConnector

net.sergeych.farcall.JsonConnector

All Implemented Interfaces:

Connector

public class JsonConnector
extends BasicConnector
implements Connector

the class to pack Farcall object tp json form and take care of Time() values too. It uses new line (LF, 0x0A, "\n") single character as line separator as it can not be contained in UTF-8 encoded JSON strings. That means the JSON should be in compact form, in one line.

For data types other than native there is reserved form: { "__type__": "type_name",...}. This implementatoins encodes java Date() instance as

     { "__type__": "datetime", "unixtime", seconds_since_epoch }
 

using standard unix time - number of seconds since epoch. Note, that it can be either integer or float to get subsecond resolution.

This class is thread safe as long as it is used properly, e.g. connected with only one endpoint like the Farcall instance.

Created by sergeych on 12.04.16.

Field Summary

Fields inherited from class net.sergeych.farcall.BasicConnector

closed, in, out

Constructor Summary

Constructors

Constructor and Description
JsonConnector(java.io.InputStream in, java.io.OutputStream out)

Method Summary

Modifier and Type	Method and Description
java.util.Map<java.lang.String,java.lang.Object>	receive() Block until the connection is closed or a valid package is received.
void	send(java.util.Map<java.lang.String,java.lang.Object> data) Pack and send farcall data

Methods inherited from class net.sergeych.farcall.BasicConnector

close, isAutoClosing, isClosed, setAutoClosing

Methods inherited from class net.sergeych.tools.JsonTool

fromJson, fromJson, toJson, toJsonString

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.sergeych.farcall.Connector

close

Constructor Detail

JsonConnector

public JsonConnector(java.io.InputStream in,
                     java.io.OutputStream out)

Method Detail

send

public void send(java.util.Map<java.lang.String,java.lang.Object> data)
          throws java.io.IOException

Description copied from interface: Connector

Pack and send farcall data

Specified by:

send in interface Connector

Throws:

java.io.IOException

receive

public java.util.Map<java.lang.String,java.lang.Object> receive()
                                                         throws java.io.IOException

Description copied from interface: Connector

Block until the connection is closed or a valid package is received. Connector unpacks the package and returns it.

Specified by:

receive in interface Connector

Returns:

unpacked data or null to signal eof state.

Throws:

java.io.IOException