public class MessageListenerSink extends AbstractQueuedCallbackSink
Constructor and Description |
---|
MessageListenerSink() |
Modifier and Type | Method and Description |
---|---|
protected void |
propagateMessage(VehicleMessage message) |
void |
register(java.lang.Class<? extends Measurement> measurementType,
Measurement.Listener listener) |
void |
register(java.lang.Class<? extends VehicleMessage> messageType,
VehicleMessage.Listener listener) |
void |
register(KeyMatcher matcher,
VehicleMessage.Listener listener) |
void |
register(KeyMatcher matcher,
VehicleMessage.Listener listener,
boolean persist) |
java.lang.String |
toString() |
void |
unregister(java.lang.Class<? extends Measurement> measurementType,
Measurement.Listener listener) |
void |
unregister(java.lang.Class<? extends VehicleMessage> messageType,
VehicleMessage.Listener listener) |
void |
unregister(KeyMatcher matcher,
VehicleMessage.Listener listener) |
clearQueue, receive, stop
public void register(KeyMatcher matcher, VehicleMessage.Listener listener, boolean persist)
public void register(KeyMatcher matcher, VehicleMessage.Listener listener)
public void register(java.lang.Class<? extends VehicleMessage> messageType, VehicleMessage.Listener listener)
public void register(java.lang.Class<? extends Measurement> measurementType, Measurement.Listener listener)
public void unregister(java.lang.Class<? extends Measurement> measurementType, Measurement.Listener listener)
public void unregister(java.lang.Class<? extends VehicleMessage> messageType, VehicleMessage.Listener listener)
public void unregister(KeyMatcher matcher, VehicleMessage.Listener listener)
public java.lang.String toString()
toString
in class java.lang.Object
protected void propagateMessage(VehicleMessage message)
propagateMessage
in class AbstractQueuedCallbackSink