EventHandlerGroup<T> |
Disruptor.after(EventHandlerIdentity... handlers) |
Create a group of event handlers to be used as a dependency.
|
EventHandlerGroup<T> |
Disruptor.after(EventProcessor... processors) |
Create a group of event processors to be used as a dependency.
|
EventHandlerGroup<T> |
EventHandlerGroup.and(EventHandlerGroup<T> otherHandlerGroup) |
Create a new event handler group that combines the consumers in this group with otherHandlerGroup.
|
EventHandlerGroup<T> |
EventHandlerGroup.and(EventProcessor... processors) |
Create a new event handler group that combines the handlers in this group with processors.
|
EventHandlerGroup<T> |
Disruptor.handleEventsWith(BatchRewindStrategy batchRewindStrategy,
RewindableEventHandler<? super T>... handlers) |
Set up event handlers to handle events from the ring buffer.
|
EventHandlerGroup<T> |
Disruptor.handleEventsWith(EventProcessorFactory<T>... eventProcessorFactories) |
Set up custom event processors to handle events from the ring buffer.
|
EventHandlerGroup<T> |
Disruptor.handleEventsWith(EventHandler<? super T>... handlers) |
Set up event handlers to handle events from the ring buffer.
|
EventHandlerGroup<T> |
Disruptor.handleEventsWith(EventProcessor... processors) |
Set up custom event processors to handle events from the ring buffer.
|
EventHandlerGroup<T> |
EventHandlerGroup.handleEventsWith(BatchRewindStrategy batchRewindStrategy,
RewindableEventHandler<? super T>... handlers) |
Set up batch handlers to handle events from the ring buffer.
|
EventHandlerGroup<T> |
EventHandlerGroup.handleEventsWith(EventProcessorFactory<T>... eventProcessorFactories) |
Set up custom event processors 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.
|
EventHandlerGroup<T> |
EventHandlerGroup.then(BatchRewindStrategy batchRewindStrategy,
RewindableEventHandler<? super T>... handlers) |
Set up batch handlers to consume events from the ring buffer.
|
EventHandlerGroup<T> |
EventHandlerGroup.then(EventProcessorFactory<T>... eventProcessorFactories) |
Set up custom event processors to handle events from the ring buffer.
|
EventHandlerGroup<T> |
EventHandlerGroup.then(EventHandler<? super T>... handlers) |
Set up batch handlers to consume events from the ring buffer.
|