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
class EventProcessorInfo<T> extends java.lang.Object implements 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
Fields Modifier and Type Field Description private SequenceBarrierbarrierprivate booleanendOfChainprivate EventProcessoreventprocessorprivate EventHandler<? super T>handler
-
Constructor Summary
Constructors Constructor Description EventProcessorInfo(EventProcessor eventprocessor, EventHandler<? super T> handler, SequenceBarrier barrier)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description SequenceBarriergetBarrier()EventProcessorgetEventProcessor()EventHandler<? super T>getHandler()Sequence[]getSequences()voidhalt()booleanisEndOfChain()booleanisRunning()voidmarkAsUsedInBarrier()voidstart(java.util.concurrent.Executor executor)
-
-
-
Field Detail
-
eventprocessor
private final EventProcessor eventprocessor
-
handler
private final EventHandler<? super T> handler
-
barrier
private final SequenceBarrier barrier
-
endOfChain
private boolean endOfChain
-
-
Constructor Detail
-
EventProcessorInfo
EventProcessorInfo(EventProcessor eventprocessor, EventHandler<? super T> handler, SequenceBarrier barrier)
-
-
Method Detail
-
getEventProcessor
public EventProcessor getEventProcessor()
-
getSequences
public Sequence[] getSequences()
- Specified by:
getSequencesin interfaceConsumerInfo
-
getHandler
public EventHandler<? super T> getHandler()
-
getBarrier
public SequenceBarrier getBarrier()
- Specified by:
getBarrierin interfaceConsumerInfo
-
isEndOfChain
public boolean isEndOfChain()
- Specified by:
isEndOfChainin interfaceConsumerInfo
-
start
public void start(java.util.concurrent.Executor executor)
- 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
-
-