Uses of Interface
com.lmax.disruptor.EventHandler
-
Packages that use EventHandler Package Description com.lmax.disruptor The Disruptor is a concurrent programming framework for exchanging and coordinating work as a continuous series of events.com.lmax.disruptor.dsl -
-
Uses of EventHandler in com.lmax.disruptor
Subinterfaces of EventHandler in com.lmax.disruptor Modifier and Type Interface Description interface
SequenceReportingEventHandler<T>
Used by theBatchEventProcessor
to set a callback allowing theEventHandler
to notify when it has finished consuming an event if this happens after theonEvent(Object, long, boolean)
call.Classes in com.lmax.disruptor that implement EventHandler Modifier and Type Class Description class
AggregateEventHandler<T>
An aggregate collection ofEventHandler
s that get called in sequence for each event.Fields in com.lmax.disruptor declared as EventHandler Modifier and Type Field Description private EventHandler<? super T>
BatchEventProcessor. eventHandler
private EventHandler<T>[]
AggregateEventHandler. eventHandlers
Constructors in com.lmax.disruptor with parameters of type EventHandler Constructor Description AggregateEventHandler(EventHandler<T>... eventHandlers)
Construct an aggregate collection ofEventHandler
s to be called in sequence.BatchEventProcessor(DataProvider<T> dataProvider, SequenceBarrier sequenceBarrier, EventHandler<? super T> eventHandler)
Construct aEventProcessor
that will automatically track the progress by updating its sequence when theonEvent(Object, long, boolean)
method returns. -
Uses of EventHandler in com.lmax.disruptor.dsl
Fields in com.lmax.disruptor.dsl declared as EventHandler Modifier and Type Field Description private EventHandler<T>
ExceptionHandlerSetting. eventHandler
private EventHandler<? super T>
EventProcessorInfo. handler
Fields in com.lmax.disruptor.dsl with type parameters of type EventHandler Modifier and Type Field Description private java.util.Map<EventHandler<?>,EventProcessorInfo<T>>
ConsumerRepository. eventProcessorInfoByEventHandler
Methods in com.lmax.disruptor.dsl that return EventHandler Modifier and Type Method Description EventHandler<? super T>
EventProcessorInfo. getHandler()
Methods in com.lmax.disruptor.dsl with parameters of type EventHandler Modifier and Type Method Description void
ConsumerRepository. add(EventProcessor eventprocessor, EventHandler<? super T> handler, SequenceBarrier barrier)
EventHandlerGroup<T>
Disruptor. after(EventHandler<T>... handlers)
Create a group of event handlers to be used as a dependency.(package private) EventHandlerGroup<T>
Disruptor. createEventProcessors(Sequence[] barrierSequences, EventHandler<? super T>[] eventHandlers)
SequenceBarrier
ConsumerRepository. getBarrierFor(EventHandler<T> handler)
SequenceBarrier
Disruptor. getBarrierFor(EventHandler<T> handler)
Get theSequenceBarrier
used by a specific handler.EventProcessor
ConsumerRepository. getEventProcessorFor(EventHandler<T> handler)
private EventProcessorInfo<T>
ConsumerRepository. getEventProcessorInfo(EventHandler<T> handler)
Sequence
ConsumerRepository. getSequenceFor(EventHandler<T> handler)
long
Disruptor. getSequenceValueFor(EventHandler<T> b1)
Gets the sequence value for the specified event handlers.EventHandlerGroup<T>
Disruptor. handleEventsWith(EventHandler<? super T>... handlers)
Set up event handlers to handle events from the ring buffer.EventHandlerGroup<T>
EventHandlerGroup. handleEventsWith(EventHandler<? super T>... handlers)
Set up batch handlers to handle events from the ring buffer.ExceptionHandlerSetting<T>
Disruptor. handleExceptionsFor(EventHandler<T> eventHandler)
Override the default exception handler for a specific handler.EventHandlerGroup<T>
EventHandlerGroup. then(EventHandler<? super T>... handlers)
Set up batch handlers to consume events from the ring buffer.Constructors in com.lmax.disruptor.dsl with parameters of type EventHandler Constructor Description EventProcessorInfo(EventProcessor eventprocessor, EventHandler<? super T> handler, SequenceBarrier barrier)
ExceptionHandlerSetting(EventHandler<T> eventHandler, ConsumerRepository<T> consumerRepository)
-