com.lmax.disruptor.dsl

Class EventProcessorInfo<T>

java.lang.Object

com.lmax.disruptor.dsl.EventProcessorInfo<T>

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 and Description
private SequenceBarrier	barrier
private boolean	endOfChain
private EventProcessor	eventprocessor
private EventHandler<? super T>	handler

Constructor Summary

Constructors

Constructor and Description
EventProcessorInfo(EventProcessor eventprocessor, EventHandler<? super T> handler, SequenceBarrier barrier)

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 interface ConsumerInfo

getHandler

public EventHandler<? super T> getHandler()

getBarrier

public SequenceBarrier getBarrier()

Specified by:

getBarrier in interface ConsumerInfo

isEndOfChain

public boolean isEndOfChain()

Specified by:

isEndOfChain in interface ConsumerInfo

start

public void start(java.util.concurrent.Executor executor)

Specified by:

start in interface ConsumerInfo

halt

public void halt()

Specified by:

halt in interface ConsumerInfo

markAsUsedInBarrier

public void markAsUsedInBarrier()

Specified by:

markAsUsedInBarrier in interface ConsumerInfo

isRunning

public boolean isRunning()

Specified by:

isRunning in interface ConsumerInfo