T
- the type of the EventHandler
class ConsumerRepository<T> extends java.lang.Object implements java.lang.Iterable<ConsumerInfo>
EventHandler
s with EventProcessor
sModifier and Type | Field and Description |
---|---|
private java.util.Collection<ConsumerInfo> |
consumerInfos |
private java.util.Map<EventHandler<?>,EventProcessorInfo<T>> |
eventProcessorInfoByEventHandler |
private java.util.Map<Sequence,ConsumerInfo> |
eventProcessorInfoBySequence |
Constructor and Description |
---|
ConsumerRepository() |
Modifier and Type | Method and 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) |
private final java.util.Map<EventHandler<?>,EventProcessorInfo<T>> eventProcessorInfoByEventHandler
private final java.util.Map<Sequence,ConsumerInfo> eventProcessorInfoBySequence
private final java.util.Collection<ConsumerInfo> consumerInfos
public void add(EventProcessor eventprocessor, EventHandler<? super T> handler, SequenceBarrier barrier)
public void add(EventProcessor processor)
public void add(WorkerPool<T> workerPool, SequenceBarrier sequenceBarrier)
public Sequence[] getLastSequenceInChain(boolean includeStopped)
public EventProcessor getEventProcessorFor(EventHandler<T> handler)
public Sequence getSequenceFor(EventHandler<T> handler)
public void unMarkEventProcessorsAsEndOfChain(Sequence... barrierEventProcessors)
public java.util.Iterator<ConsumerInfo> iterator()
iterator
in interface java.lang.Iterable<ConsumerInfo>
public SequenceBarrier getBarrierFor(EventHandler<T> handler)
private EventProcessorInfo<T> getEventProcessorInfo(EventHandler<T> handler)
private ConsumerInfo getEventProcessorInfo(Sequence barrierEventProcessor)