org.nuxeo.lib.stream.pattern.consumer

Class ConsumerPool<M extends Message>

java.lang.Object

org.nuxeo.lib.stream.pattern.consumer.internals.AbstractCallablePool<ConsumerStatus>

org.nuxeo.lib.stream.pattern.consumer.ConsumerPool<M>

All Implemented Interfaces:

AutoCloseable

Direct Known Subclasses:

DocumentConsumerPool

public class ConsumerPool<M extends Message>
extends AbstractCallablePool<ConsumerStatus>

Run a pool of ConsumerRunner.

Since:

9.1

Nested Class Summary

Nested classes/interfaces inherited from class org.nuxeo.lib.stream.pattern.consumer.internals.AbstractCallablePool

AbstractCallablePool.NamedThreadFactory

Field Summary

Fields

Modifier and Type	Field and Description
protected List<List<LogPartition>>	defaultAssignments
protected ConsumerFactory<M>	factory
protected String	logName
protected LogManager	manager
protected ConsumerPolicy	policy

Fields inherited from class org.nuxeo.lib.stream.pattern.consumer.internals.AbstractCallablePool

nbThreads, supplyThreadPool, threadPool

Constructor Summary

Constructors

Constructor and Description
ConsumerPool(String logName, LogManager manager, ConsumerFactory<M> factory, ConsumerPolicy policy)

Method Summary

Modifier and Type	Method and Description
protected void	afterCall(List<ConsumerStatus> ret)
protected static short	computeNbThreads(short maxConcurrency, short maxThreads)
protected Callable<ConsumerStatus>	getCallable(int i)
String	getConsumerGroupName()
protected List<List<LogPartition>>	getDefaultAssignments()
protected ConsumerStatus	getErrorStatus() Value to return when there was an exception during execution
protected String	getThreadPrefix()

Methods inherited from class org.nuxeo.lib.stream.pattern.consumer.internals.AbstractCallablePool

close, getNbThreads, runPool, start

Methods inherited from class java.lang.Object

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

Field Detail

manager

protected final LogManager manager

factory

protected final ConsumerFactory<M extends Message> factory

policy

protected final ConsumerPolicy policy

logName

protected final String logName

defaultAssignments

protected final List<List<LogPartition>> defaultAssignments

Constructor Detail

ConsumerPool

public ConsumerPool(String logName,
                    LogManager manager,
                    ConsumerFactory<M> factory,
                    ConsumerPolicy policy)

Method Detail

computeNbThreads

protected static short computeNbThreads(short maxConcurrency,
                                        short maxThreads)

getConsumerGroupName

public String getConsumerGroupName()

getErrorStatus

protected ConsumerStatus getErrorStatus()

Description copied from class: AbstractCallablePool

Value to return when there was an exception during execution

Specified by:

getErrorStatus in class AbstractCallablePool<ConsumerStatus>

getCallable

protected Callable<ConsumerStatus> getCallable(int i)

Specified by:

getCallable in class AbstractCallablePool<ConsumerStatus>

getThreadPrefix

protected String getThreadPrefix()

Specified by:

getThreadPrefix in class AbstractCallablePool<ConsumerStatus>

afterCall

protected void afterCall(List<ConsumerStatus> ret)

Specified by:

afterCall in class AbstractCallablePool<ConsumerStatus>

getDefaultAssignments

protected List<List<LogPartition>> getDefaultAssignments()