Package 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

Field Summary

Fields

Modifier and Type	Field	Description
protected Codec<M>	codec
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	Description
ConsumerPool(String logName, LogManager manager, Codec<M> codec, ConsumerFactory<M> factory, ConsumerPolicy policy)
ConsumerPool(String logName, LogManager manager, ConsumerFactory<M> factory, ConsumerPolicy policy)	Deprecated. since 11.1, due to serialization issue with java 11, use ConsumerPool(String, LogManager, Codec, ConsumerFactory, ConsumerPolicy) which allows to give a codec to tailer.

Method Summary

Modifier and Type	Method	Description
protected void	afterCall(List<ConsumerStatus> ret)
protected static short	computeNbThreads(short maxConcurrency, short maxThreads)
protected Callable<ConsumerStatus>	getCallable(int i)
Name	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

logName

protected final String logName

manager

protected final LogManager manager

codec

protected final Codec<M extends Message> codec

factory

protected final ConsumerFactory<M extends Message> factory

policy

protected final ConsumerPolicy policy

defaultAssignments

protected final List<List<LogPartition>> defaultAssignments

Constructor Detail

ConsumerPool

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

Deprecated.

since 11.1, due to serialization issue with java 11, use ConsumerPool(String, LogManager, Codec, ConsumerFactory, ConsumerPolicy) which allows to give a codec to tailer.

ConsumerPool

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

Method Detail

computeNbThreads

protected static short computeNbThreads(short maxConcurrency,
                                        short maxThreads)

getConsumerGroupName

public Name 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()