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 TypeInterfaceDescriptioninterface
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 EventHandlerModifier and TypeClassDescriptionfinal class
An aggregate collection ofEventHandler
s that get called in sequence for each event.Fields in com.lmax.disruptor declared as EventHandlerModifier and TypeFieldDescriptionprivate final EventHandler
<? super T> BatchEventProcessor.eventHandler
private final EventHandler<T>[]
AggregateEventHandler.eventHandlers
Constructors in com.lmax.disruptor with parameters of type EventHandlerModifierConstructorDescriptionAggregateEventHandler
(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 EventHandlerModifier and TypeFieldDescriptionprivate final EventHandler
<T> ExceptionHandlerSetting.eventHandler
private final EventHandler
<? super T> EventProcessorInfo.handler
Fields in com.lmax.disruptor.dsl with type parameters of type EventHandlerModifier and TypeFieldDescriptionprivate final Map
<EventHandler<?>, EventProcessorInfo<T>> ConsumerRepository.eventProcessorInfoByEventHandler
Methods in com.lmax.disruptor.dsl that return EventHandlerMethods in com.lmax.disruptor.dsl with parameters of type EventHandlerModifier and TypeMethodDescriptionvoid
ConsumerRepository.add
(EventProcessor eventprocessor, EventHandler<? super T> handler, SequenceBarrier barrier) final 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) ConsumerRepository.getBarrierFor
(EventHandler<T> handler) Disruptor.getBarrierFor
(EventHandler<T> handler) Get theSequenceBarrier
used by a specific handler.ConsumerRepository.getEventProcessorFor
(EventHandler<T> handler) private EventProcessorInfo
<T> ConsumerRepository.getEventProcessorInfo
(EventHandler<T> handler) ConsumerRepository.getSequenceFor
(EventHandler<T> handler) long
Disruptor.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.Constructors in com.lmax.disruptor.dsl with parameters of type EventHandlerModifierConstructorDescription(package private)
EventProcessorInfo
(EventProcessor eventprocessor, EventHandler<? super T> handler, SequenceBarrier barrier) (package private)
ExceptionHandlerSetting
(EventHandler<T> eventHandler, ConsumerRepository<T> consumerRepository)