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 SequenceBarrierprivate booleanprivate final EventProcessorprivate final EventHandler<? super T> -
Constructor Summary
ConstructorsConstructorDescriptionEventProcessorInfo(EventProcessor eventprocessor, EventHandler<? super T> handler, SequenceBarrier barrier) -
Method Summary
Modifier and TypeMethodDescriptionEventHandler<? super T> Sequence[]voidhalt()booleanbooleanvoidvoid
-
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:
getSequencesin interfaceConsumerInfo
-
getHandler
-
getBarrier
- Specified by:
getBarrierin interfaceConsumerInfo
-
isEndOfChain
public boolean isEndOfChain()- Specified by:
isEndOfChainin interfaceConsumerInfo
-
start
- Specified by:
startin interfaceConsumerInfo
-
halt
public void halt()- Specified by:
haltin interfaceConsumerInfo
-
markAsUsedInBarrier
public void markAsUsedInBarrier()- Specified by:
markAsUsedInBarrierin interfaceConsumerInfo
-
isRunning
public boolean isRunning()- Specified by:
isRunningin interfaceConsumerInfo
-