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 |
Modifier and Type | Interface and Description |
---|---|
interface |
SequenceReportingEventHandler<T>
Used by the
BatchEventProcessor to set a callback allowing the EventHandler to notify
when it has finished consuming an event if this happens after the onEvent(Object, long, boolean) call. |
Modifier and Type | Class and Description |
---|---|
class |
AggregateEventHandler<T>
An aggregate collection of
EventHandler s that get called in sequence for each event. |
Modifier and Type | Field and Description |
---|---|
private EventHandler<? super T> |
BatchEventProcessor.eventHandler |
private EventHandler<T>[] |
AggregateEventHandler.eventHandlers |
Constructor and Description |
---|
AggregateEventHandler(EventHandler<T>... eventHandlers)
Construct an aggregate collection of
EventHandler s to be called in sequence. |
BatchEventProcessor(DataProvider<T> dataProvider,
SequenceBarrier sequenceBarrier,
EventHandler<? super T> eventHandler)
Construct a
EventProcessor that will automatically track the progress by updating its sequence when
the onEvent(Object, long, boolean) method returns. |
Modifier and Type | Field and Description |
---|---|
private EventHandler<T> |
ExceptionHandlerSetting.eventHandler |
private EventHandler<? super T> |
EventProcessorInfo.handler |
Modifier and Type | Field and Description |
---|---|
private java.util.Map<EventHandler<?>,EventProcessorInfo<T>> |
ConsumerRepository.eventProcessorInfoByEventHandler |
Modifier and Type | Method and Description |
---|---|
EventHandler<? super T> |
EventProcessorInfo.getHandler() |
Modifier and Type | Method and 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 |
Disruptor.getBarrierFor(EventHandler<T> handler)
Get the
SequenceBarrier used by a specific handler. |
SequenceBarrier |
ConsumerRepository.getBarrierFor(EventHandler<T> 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.
|
Constructor and Description |
---|
EventProcessorInfo(EventProcessor eventprocessor,
EventHandler<? super T> handler,
SequenceBarrier barrier) |
ExceptionHandlerSetting(EventHandler<T> eventHandler,
ConsumerRepository<T> consumerRepository) |