Package | Description |
---|---|
com.lmax.disruptor.dsl |
Modifier and Type | Method and Description |
---|---|
EventHandlerGroup<T> |
Disruptor.after(EventHandler<T>... 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.
|
(package private) EventHandlerGroup<T> |
Disruptor.createEventProcessors(Sequence[] barrierSequences,
EventHandler<? super T>[] eventHandlers) |
(package private) EventHandlerGroup<T> |
Disruptor.createEventProcessors(Sequence[] barrierSequences,
EventProcessorFactory<T>[] processorFactories) |
(package private) EventHandlerGroup<T> |
Disruptor.createWorkerPool(Sequence[] barrierSequences,
WorkHandler<? super T>[] workHandlers) |
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.
|
EventHandlerGroup<T> |
Disruptor.handleEventsWith(EventProcessor... processors)
Set up custom event processors 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> |
EventHandlerGroup.handleEventsWith(EventProcessorFactory<T>... eventProcessorFactories)
Set up custom event processors to handle events from the ring buffer.
|
EventHandlerGroup<T> |
EventHandlerGroup.handleEventsWithWorkerPool(WorkHandler<? super T>... handlers)
Set up a worker pool to handle events from the ring buffer.
|
EventHandlerGroup<T> |
Disruptor.handleEventsWithWorkerPool(WorkHandler<T>... workHandlers)
Set up a
WorkerPool to distribute an event to one of a pool of work handler threads. |
EventHandlerGroup<T> |
EventHandlerGroup.then(EventHandler<? 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.thenHandleEventsWithWorkerPool(WorkHandler<? super T>... handlers)
Set up a worker pool to handle events from the ring buffer.
|
Modifier and Type | Method and Description |
---|---|
EventHandlerGroup<T> |
EventHandlerGroup.and(EventHandlerGroup<T> otherHandlerGroup)
Create a new event handler group that combines the consumers in this group with otherHandlerGroup.
|