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.
Modifier and Type | Field and Description |
---|---|
private SequenceBarrier |
barrier |
private boolean |
endOfChain |
private EventProcessor |
eventprocessor |
private EventHandler<? super T> |
handler |
Constructor and Description |
---|
EventProcessorInfo(EventProcessor eventprocessor,
EventHandler<? super T> handler,
SequenceBarrier barrier) |
Modifier and Type | Method and 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) |
private final EventProcessor eventprocessor
private final EventHandler<? super T> handler
private final SequenceBarrier barrier
private boolean endOfChain
EventProcessorInfo(EventProcessor eventprocessor, EventHandler<? super T> handler, SequenceBarrier barrier)
public EventProcessor getEventProcessor()
public Sequence[] getSequences()
getSequences
in interface ConsumerInfo
public EventHandler<? super T> getHandler()
public SequenceBarrier getBarrier()
getBarrier
in interface ConsumerInfo
public boolean isEndOfChain()
isEndOfChain
in interface ConsumerInfo
public void start(java.util.concurrent.Executor executor)
start
in interface ConsumerInfo
public void halt()
halt
in interface ConsumerInfo
public void markAsUsedInBarrier()
markAsUsedInBarrier
in interface ConsumerInfo
public boolean isRunning()
isRunning
in interface ConsumerInfo