Package com.lmax.disruptor.dsl

Class EventProcessorInfo

java.lang.Object

com.lmax.disruptor.dsl.EventProcessorInfo

All Implemented Interfaces:

ConsumerInfo

class EventProcessorInfo
extends 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 final SequenceBarrier	barrier
private boolean	endOfChain
private final EventProcessor	eventprocessor

Constructor Summary

Constructors

Constructor	Description
EventProcessorInfo(EventProcessor eventprocessor, SequenceBarrier barrier)

Method Summary

Modifier and Type	Method	Description
SequenceBarrier	getBarrier()
EventProcessor	getEventProcessor()
Sequence[]	getSequences()
void	halt()
boolean	isEndOfChain()
boolean	isRunning()
void	markAsUsedInBarrier()
void	start(ThreadFactory threadFactory)

Methods inherited from class java.lang.Object

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

Field Details

eventprocessor

private final EventProcessor eventprocessor

barrier

private final SequenceBarrier barrier

endOfChain

private boolean endOfChain

Constructor Details

EventProcessorInfo

EventProcessorInfo(EventProcessor eventprocessor,
 SequenceBarrier barrier)

Method Details

getEventProcessor

public EventProcessor getEventProcessor()

getSequences

public Sequence[] getSequences()

Specified by:

getSequences in interface ConsumerInfo

getBarrier

public SequenceBarrier getBarrier()

Specified by:

getBarrier in interface ConsumerInfo

isEndOfChain

public boolean isEndOfChain()

Specified by:

isEndOfChain in interface ConsumerInfo

start

public void start(ThreadFactory threadFactory)

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