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|
|Modifier and Type||Method and Description|
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
addListener, listeners, postToAll
public void onDropEvent(SparkListenerEvent event)
onDropEvent can be called in any thread.