com.openxc.messages.streamers

Class VehicleMessageStreamer

java.lang.Object

com.openxc.messages.streamers.VehicleMessageStreamer

Direct Known Subclasses:

BinaryStreamer, JsonStreamer

public abstract class VehicleMessageStreamer
extends java.lang.Object

A base class for VehicleMessage streamers that defines the interface and handles counting the amount of data received.

Constructor Summary

Constructors

Constructor and Description
VehicleMessageStreamer()

Method Summary

Modifier and Type	Method and Description
abstract java.lang.String	getRawMessage()
abstract VehicleMessage	parseMessage(java.lang.String line)
abstract 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.
abstract 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

VehicleMessageStreamer

public VehicleMessageStreamer()

Method Detail

parseNextMessage

public abstract VehicleMessage parseNextMessage()

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

Returns:

the next deserialized VehicleMessage.

parseMessage

public abstract VehicleMessage parseMessage(java.lang.String line)

getRawMessage

public abstract java.lang.String getRawMessage()

serializeForStream

public abstract byte[] serializeForStream(VehicleMessage message)
                                   throws SerializationException

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

Parameters:

message - the message to serialize.

Throws:

SerializationException - if the message cannot be serialized.

receive

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

Add additional bytes to the buffer from the data source.

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.