public class LiveListenerBus extends AsynchronousListenerBus<SparkListener,SparkListenerEvent> implements SparkListenerBus
Until start() is called, all posted events are only buffered. Only after this listener bus has started will events be actually propagated to all attached listeners. This listener bus is stopped when it receives a SparkListenerShutdown event, which is posted using stop().
Constructor and Description |
---|
LiveListenerBus() |
Modifier and Type | Method and Description |
---|---|
void |
onDropEvent(SparkListenerEvent event)
If the event queue exceeds its capacity, the new events will be dropped.
|
listenerThreadIsAlive, post, start, stop, waitUntilEmpty
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onPostEvent
addListener, listeners, postToAll
initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning
public void onDropEvent(SparkListenerEvent event)
AsynchronousListenerBus
Note: onDropEvent
can be called in any thread.
onDropEvent
in class AsynchronousListenerBus<SparkListener,SparkListenerEvent>