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 SequenceBarrier
barrier
private boolean
endOfChain
private EventProcessor
eventprocessor
private 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 SequenceBarrier
getBarrier()
EventProcessor
getEventProcessor()
EventHandler<? super T>
getHandler()
Sequence[]
getSequences()
void
halt()
boolean
isEndOfChain()
boolean
isRunning()
void
markAsUsedInBarrier()
void
start(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:
getSequences
in interfaceConsumerInfo
-
getHandler
public EventHandler<? super T> getHandler()
-
getBarrier
public SequenceBarrier getBarrier()
- Specified by:
getBarrier
in interfaceConsumerInfo
-
isEndOfChain
public boolean isEndOfChain()
- Specified by:
isEndOfChain
in interfaceConsumerInfo
-
start
public void start(java.util.concurrent.Executor executor)
- 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
-
-