Uses of Interface
com.lmax.disruptor.EventHandler
Packages that use EventHandler
Package
Description
The Disruptor is a concurrent programming framework for exchanging and coordinating work as a continuous series of events.
-
Uses of EventHandler in com.lmax.disruptor
Subinterfaces of EventHandler in com.lmax.disruptorModifier and TypeInterfaceDescriptioninterfaceUsed by theBatchEventProcessorto set a callback allowing theEventHandlerto notify when it has finished consuming an event if this happens after theEventHandler.onEvent(Object, long, boolean)call.Classes in com.lmax.disruptor that implement EventHandlerModifier and TypeClassDescriptionfinal classAn aggregate collection ofEventHandlers that get called in sequence for each event.Constructors in com.lmax.disruptor with parameters of type EventHandlerModifierConstructorDescriptionAggregateEventHandler(EventHandler<T>... eventHandlers) Construct an aggregate collection ofEventHandlers to be called in sequence.BatchEventProcessor(DataProvider<T> dataProvider, SequenceBarrier sequenceBarrier, EventHandler<? super T> eventHandler) Construct aEventProcessorthat will automatically track the progress by updating its sequence when theEventHandler.onEvent(Object, long, boolean)method returns. -
Uses of EventHandler in com.lmax.disruptor.dsl
Methods in com.lmax.disruptor.dsl with parameters of type EventHandlerModifier and TypeMethodDescriptionfinal EventHandlerGroup<T> Disruptor.after(EventHandler<T>... handlers) Create a group of event handlers to be used as a dependency.Disruptor.getBarrierFor(EventHandler<T> handler) Get theSequenceBarrierused by a specific handler.longDisruptor.getSequenceValueFor(EventHandler<T> b1) Gets the sequence value for the specified event handlers.final EventHandlerGroup<T> Disruptor.handleEventsWith(EventHandler<? super T>... handlers) Set up event handlers to handle events from the ring buffer.final EventHandlerGroup<T> EventHandlerGroup.handleEventsWith(EventHandler<? super T>... handlers) Set up batch handlers to handle events from the ring buffer.Disruptor.handleExceptionsFor(EventHandler<T> eventHandler) Override the default exception handler for a specific handler.final EventHandlerGroup<T> EventHandlerGroup.then(EventHandler<? super T>... handlers) Set up batch handlers to consume events from the ring buffer.