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 interfaceSequenceReportingEventHandler<T>Used by theBatchEventProcessorto set a callback allowing theEventHandlerto 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 classAggregateEventHandler<T>An aggregate collection ofEventHandlers 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. eventHandlerprivate EventHandler<T>[]AggregateEventHandler. eventHandlersConstructors in com.lmax.disruptor with parameters of type EventHandler Constructor Description AggregateEventHandler(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 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. eventHandlerprivate EventHandler<? super T>EventProcessorInfo. handlerFields in com.lmax.disruptor.dsl with type parameters of type EventHandler Modifier and Type Field Description private java.util.Map<EventHandler<?>,EventProcessorInfo<T>>ConsumerRepository. eventProcessorInfoByEventHandlerMethods 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 voidConsumerRepository. 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)SequenceBarrierConsumerRepository. getBarrierFor(EventHandler<T> handler)SequenceBarrierDisruptor. getBarrierFor(EventHandler<T> handler)Get theSequenceBarrierused by a specific handler.EventProcessorConsumerRepository. getEventProcessorFor(EventHandler<T> handler)private EventProcessorInfo<T>ConsumerRepository. getEventProcessorInfo(EventHandler<T> handler)SequenceConsumerRepository. getSequenceFor(EventHandler<T> handler)longDisruptor. 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)
-