Package com.lmax.disruptor.dsl

Class ConsumerRepository<T>

java.lang.Object

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

Type Parameters:

T - the type of the EventHandler

All Implemented Interfaces:

java.lang.Iterable<ConsumerInfo>

class ConsumerRepository<T>
extends java.lang.Object
implements java.lang.Iterable<ConsumerInfo>

Provides a repository mechanism to associate EventHandlers with EventProcessors

Field Summary

Fields

Modifier and Type	Field	Description
private java.util.Collection<ConsumerInfo>	consumerInfos
private java.util.Map<EventHandler<?>,EventProcessorInfo<T>>	eventProcessorInfoByEventHandler
private java.util.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, EventHandler<? super T> handler, SequenceBarrier barrier)
void	add(WorkerPool<T> workerPool, SequenceBarrier sequenceBarrier)
SequenceBarrier	getBarrierFor(EventHandler<T> handler)
EventProcessor	getEventProcessorFor(EventHandler<T> handler)
private EventProcessorInfo<T>	getEventProcessorInfo(EventHandler<T> handler)
private ConsumerInfo	getEventProcessorInfo(Sequence barrierEventProcessor)
Sequence[]	getLastSequenceInChain(boolean includeStopped)
Sequence	getSequenceFor(EventHandler<T> handler)
java.util.Iterator<ConsumerInfo>	iterator()
void	unMarkEventProcessorsAsEndOfChain(Sequence... barrierEventProcessors)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

eventProcessorInfoByEventHandler

private final java.util.Map<EventHandler<?>,EventProcessorInfo<T>> eventProcessorInfoByEventHandler

eventProcessorInfoBySequence

private final java.util.Map<Sequence,ConsumerInfo> eventProcessorInfoBySequence

consumerInfos

private final java.util.Collection<ConsumerInfo> consumerInfos

Constructor Detail

ConsumerRepository

ConsumerRepository()

Method Detail

add

public void add(EventProcessor eventprocessor,
                EventHandler<? super T> handler,
                SequenceBarrier barrier)

add

public void add(EventProcessor processor)

add

public void add(WorkerPool<T> workerPool,
                SequenceBarrier sequenceBarrier)

getLastSequenceInChain

public Sequence[] getLastSequenceInChain(boolean includeStopped)

getEventProcessorFor

public EventProcessor getEventProcessorFor(EventHandler<T> handler)

getSequenceFor

public Sequence getSequenceFor(EventHandler<T> handler)

unMarkEventProcessorsAsEndOfChain

public void unMarkEventProcessorsAsEndOfChain(Sequence... barrierEventProcessors)

iterator

public java.util.Iterator<ConsumerInfo> iterator()

Specified by:

iterator in interface java.lang.Iterable<T>

getBarrierFor

public SequenceBarrier getBarrierFor(EventHandler<T> handler)

getEventProcessorInfo

private EventProcessorInfo<T> getEventProcessorInfo(EventHandler<T> handler)

getEventProcessorInfo

private ConsumerInfo getEventProcessorInfo(Sequence barrierEventProcessor)