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, stoppublic 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.Objectprotected void propagateMessage(VehicleMessage message)
propagateMessage in class AbstractQueuedCallbackSink