Uses of Interface
com.lmax.disruptor.RewindableEventHandler
Packages that use RewindableEventHandler
Package
Description
The Disruptor is a concurrent programming framework for exchanging and coordinating work as a continuous series of events.
A DSL-style API for setting up the disruptor pattern around a ring buffer.
-
Uses of RewindableEventHandler in com.lmax.disruptor
Methods in com.lmax.disruptor with parameters of type RewindableEventHandlerModifier and TypeMethodDescription<T> BatchEventProcessor<T> BatchEventProcessorBuilder.build(DataProvider<T> dataProvider, SequenceBarrier sequenceBarrier, RewindableEventHandler<? super T> rewindableEventHandler, BatchRewindStrategy batchRewindStrategy) Construct aEventProcessorthat will automatically track the progress by updating its sequence when theEventHandler.onEvent(Object, long, boolean)method returns. -
Uses of RewindableEventHandler in com.lmax.disruptor.dsl
Methods in com.lmax.disruptor.dsl with parameters of type RewindableEventHandlerModifier and TypeMethodDescription(package private) EventHandlerGroup<T> Disruptor.createEventProcessors(Sequence[] barrierSequences, BatchRewindStrategy batchRewindStrategy, RewindableEventHandler<? super T>[] eventHandlers) final EventHandlerGroup<T> Disruptor.handleEventsWith(BatchRewindStrategy batchRewindStrategy, RewindableEventHandler<? super T>... handlers) Set up event handlers to handle events from the ring buffer.final EventHandlerGroup<T> EventHandlerGroup.handleEventsWith(BatchRewindStrategy batchRewindStrategy, RewindableEventHandler<? super T>... handlers) Set up batch handlers to handle events from the ring buffer.final EventHandlerGroup<T> EventHandlerGroup.then(BatchRewindStrategy batchRewindStrategy, RewindableEventHandler<? super T>... handlers) Set up batch handlers to consume events from the ring buffer.