Package com.lmax.disruptor.dsl

Class ConsumerRepository

java.lang.Object

com.lmax.disruptor.dsl.ConsumerRepository

class ConsumerRepository
extends Object

Provides a repository mechanism to associate EventHandlers with EventProcessors

Field Summary

Fields

Modifier and Type	Field	Description
private final Collection<ConsumerInfo>	consumerInfos
private final Map<EventHandlerIdentity,EventProcessorInfo>	eventProcessorInfoByEventHandler
private final Map<Sequence,ConsumerInfo>	eventProcessorInfoBySequence

Constructor Summary

Constructors

Constructor	Description
ConsumerRepository()

Method Summary

Modifier and Type	Method	Description
void	add(EventProcessor processor)
void	add(EventProcessor eventprocessor, EventHandlerIdentity handlerIdentity, SequenceBarrier barrier)
SequenceBarrier	getBarrierFor(EventHandlerIdentity handlerIdentity)
EventProcessor	getEventProcessorFor(EventHandlerIdentity handlerIdentity)
private EventProcessorInfo	getEventProcessorInfo(EventHandlerIdentity handlerIdentity)
private ConsumerInfo	getEventProcessorInfo(Sequence barrierEventProcessor)
Sequence	getSequenceFor(EventHandlerIdentity handlerIdentity)
void	haltAll()
boolean	hasBacklog(long cursor, boolean includeStopped)
void	startAll(ThreadFactory threadFactory)
void	unMarkEventProcessorsAsEndOfChain(Sequence... barrierEventProcessors)

Methods inherited from class java.lang.Object

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

Field Details

eventProcessorInfoByEventHandler

private final Map<EventHandlerIdentity,EventProcessorInfo> eventProcessorInfoByEventHandler

eventProcessorInfoBySequence

private final Map<Sequence,ConsumerInfo> eventProcessorInfoBySequence

consumerInfos

private final Collection<ConsumerInfo> consumerInfos

Constructor Details

ConsumerRepository

ConsumerRepository()

Method Details

add

public void add(EventProcessor eventprocessor,
 EventHandlerIdentity handlerIdentity,
 SequenceBarrier barrier)

add

public void add(EventProcessor processor)

startAll

public void startAll(ThreadFactory threadFactory)

haltAll

public void haltAll()

hasBacklog

public boolean hasBacklog(long cursor,
 boolean includeStopped)

getEventProcessorFor

public EventProcessor getEventProcessorFor(EventHandlerIdentity handlerIdentity)

getSequenceFor

public Sequence getSequenceFor(EventHandlerIdentity handlerIdentity)

unMarkEventProcessorsAsEndOfChain

public void unMarkEventProcessorsAsEndOfChain(Sequence... barrierEventProcessors)

getBarrierFor

public SequenceBarrier getBarrierFor(EventHandlerIdentity handlerIdentity)

getEventProcessorInfo

private EventProcessorInfo getEventProcessorInfo(EventHandlerIdentity handlerIdentity)

getEventProcessorInfo

private ConsumerInfo getEventProcessorInfo(Sequence barrierEventProcessor)