Package com.lmax.disruptor.dsl
Class EventProcessorInfo<T>
java.lang.Object
com.lmax.disruptor.dsl.EventProcessorInfo<T>
- Type Parameters:
T
- the type of the configuredEventHandler
- All Implemented Interfaces:
ConsumerInfo
Wrapper class to tie together a particular event processing stage
Tracks the event processor instance, the event handler instance, and sequence barrier which the stage is attached to.
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final SequenceBarrier
private boolean
private final EventProcessor
private final EventHandler
<? super T> -
Constructor Summary
ConstructorsConstructorDescriptionEventProcessorInfo
(EventProcessor eventprocessor, EventHandler<? super T> handler, SequenceBarrier barrier) -
Method Summary
Modifier and TypeMethodDescriptionEventHandler
<? super T> Sequence[]
void
halt()
boolean
boolean
void
void
-
Field Details
-
eventprocessor
-
handler
-
barrier
-
endOfChain
private boolean endOfChain
-
-
Constructor Details
-
EventProcessorInfo
EventProcessorInfo(EventProcessor eventprocessor, EventHandler<? super T> handler, SequenceBarrier barrier)
-
-
Method Details
-
getEventProcessor
-
getSequences
- Specified by:
getSequences
in interfaceConsumerInfo
-
getHandler
-
getBarrier
- Specified by:
getBarrier
in interfaceConsumerInfo
-
isEndOfChain
public boolean isEndOfChain()- Specified by:
isEndOfChain
in interfaceConsumerInfo
-
start
- Specified by:
start
in interfaceConsumerInfo
-
halt
public void halt()- Specified by:
halt
in interfaceConsumerInfo
-
markAsUsedInBarrier
public void markAsUsedInBarrier()- Specified by:
markAsUsedInBarrier
in interfaceConsumerInfo
-
isRunning
public boolean isRunning()- Specified by:
isRunning
in interfaceConsumerInfo
-