public class StreamingListenerBus extends AsynchronousListenerBus<StreamingListener,StreamingListenerEvent> implements Logging
Constructor and Description |
---|
StreamingListenerBus() |
Modifier and Type | Method and Description |
---|---|
void |
onDropEvent(StreamingListenerEvent event)
If the event queue exceeds its capacity, the new events will be dropped.
|
void |
onPostEvent(StreamingListener listener,
StreamingListenerEvent event)
Post an event to the specified listener.
|
listenerThreadIsAlive, post, start, stop, waitUntilEmpty
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning
addListener, listeners, postToAll
public void onPostEvent(StreamingListener listener, StreamingListenerEvent event)
ListenerBus
onPostEvent
is guaranteed to be called in the same
thread.onPostEvent
in interface ListenerBus<StreamingListener,StreamingListenerEvent>
public void onDropEvent(StreamingListenerEvent event)
AsynchronousListenerBus
Note: onDropEvent
can be called in any thread.
onDropEvent
in class AsynchronousListenerBus<StreamingListener,StreamingListenerEvent>