org.nuxeo.ecm.platform.importer.mqueues.pattern.consumer

Class ConsumerPool<M extends Message>

java.lang.Object

org.nuxeo.ecm.platform.importer.mqueues.pattern.consumer.internals.AbstractCallablePool<ConsumerStatus>

org.nuxeo.ecm.platform.importer.mqueues.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.ecm.platform.importer.mqueues.pattern.consumer.internals.AbstractCallablePool

AbstractCallablePool.NamedThreadFactory

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class org.nuxeo.ecm.platform.importer.mqueues.pattern.consumer.internals.AbstractCallablePool

getNbThreads, runPool, start

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsumerPool

public ConsumerPool(String mqName,
                    MQManager<M> 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>

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Overrides:

close in class AbstractCallablePool<ConsumerStatus>

Throws:

Exception