com.openxc.messages.streamers

Class JsonStreamer

java.lang.Object

com.openxc.messages.streamers.VehicleMessageStreamer

com.openxc.messages.streamers.JsonStreamer

public class JsonStreamer
extends VehicleMessageStreamer

A class to deserialize and serialize JSON-formatted vehicle messages from byte streams. The JsonStreamer wraps the JsonFormatter and handles messages delimiting. It uses a delimiter as specified by the OpenXC message format. Unlike the JsonFormatter, the JsonStreamer is not stateless. It maintains an internal buffer of bytes so that if partial messages is received it can eventually receive an parse the entire thing.

Constructor Summary

Constructors

Constructor and Description
JsonStreamer()

Method Summary

Modifier and Type	Method and Description
static boolean	containsJson(java.lang.String buffer) Return true if the buffer *most likely* contains JSON (as opposed to a protobuf).
java.lang.String	getRawMessage()
VehicleMessage	parseMessage(java.lang.String line)
VehicleMessage	parseNextMessage() Deserialize and return the next messages from the internally buffered stream.
void	receive(byte[] bytes, int length) Add additional bytes to the buffer from the data source.
byte[]	serializeForStream(VehicleMessage message) Serialize the message and insert any required delimiters for insertion into a message stream.

Methods inherited from class java.lang.Object

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

Constructor Detail

JsonStreamer

public JsonStreamer()

Method Detail

containsJson

public static boolean containsJson(java.lang.String buffer)

Return true if the buffer *most likely* contains JSON (as opposed to a protobuf).

parseNextMessage

public VehicleMessage parseNextMessage()

Description copied from class: VehicleMessageStreamer

Deserialize and return the next messages from the internally buffered stream.

Specified by:

parseNextMessage in class VehicleMessageStreamer

Returns:

the next deserialized VehicleMessage.

parseMessage

public VehicleMessage parseMessage(java.lang.String line)

Specified by:

parseMessage in class VehicleMessageStreamer

getRawMessage

public java.lang.String getRawMessage()

Specified by:

getRawMessage in class VehicleMessageStreamer

receive

public void receive(byte[] bytes,
                    int length)

Description copied from class: VehicleMessageStreamer

Add additional bytes to the buffer from the data source.

Overrides:

receive in class VehicleMessageStreamer

Parameters:

bytes - an array of bytes received from the interface.

length - number of bytes received, and thus the amount that should be read from the array.

serializeForStream

public byte[] serializeForStream(VehicleMessage message)

Description copied from class: VehicleMessageStreamer

Serialize the message and insert any required delimiters for insertion into a message stream.

Specified by:

serializeForStream in class VehicleMessageStreamer

Parameters:

message - the message to serialize.