com.openxc.sinks

Class UserSink

java.lang.Object

com.openxc.sinks.UserSink

All Implemented Interfaces:

VehicleDataSink

public class UserSink
extends java.lang.Object
implements VehicleDataSink

Pass measurements from a user-level data sources back to the remote VehicleService. This sink is a bit of a special case - it's used by the VehicleManager to pass measurement updates from a user's data sources back to the VehicleService, so it can propagate them to all OpenXC apps.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	UNABLE_TO_SEND_MESSAGE_TO_REMOTE_SERVICE

Constructor Summary

Constructors

Constructor and Description
UserSink(VehicleServiceInterface service) Registers a measurement listener with the remote service.

Method Summary

Modifier and Type	Method and Description
void	receive(VehicleMessage measurement) Receive a data point with a name, a value and a event value.
void	stop() Release any acquired resources and either stop sending measurements (if a source) or stop expecting to receive them (if a sink).
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

UNABLE_TO_SEND_MESSAGE_TO_REMOTE_SERVICE

public static final java.lang.String UNABLE_TO_SEND_MESSAGE_TO_REMOTE_SERVICE

See Also:

Constant Field Values

Constructor Detail

UserSink

public UserSink(VehicleServiceInterface service)

Registers a measurement listener with the remote service.

Method Detail

receive

public void receive(VehicleMessage measurement)

Description copied from interface: VehicleDataSink

Receive a data point with a name, a value and a event value. The implementation of this method should not block, lest the vehicle data source get behind in processing data from a source potentially external to the system.

Specified by:

receive in interface VehicleDataSink

Parameters:

measurement - The new measurement.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

stop

public void stop()

Description copied from interface: VehicleDataSink

Release any acquired resources and either stop sending measurements (if a source) or stop expecting to receive them (if a sink).

Specified by:

stop in interface VehicleDataSink