org.nuxeo.lib.stream.pattern.producer

Class ProducerPool<M extends Message>

java.lang.Object

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

org.nuxeo.lib.stream.pattern.producer.ProducerPool<M>

All Implemented Interfaces:

AutoCloseable

public class ProducerPool<M extends Message>
extends AbstractCallablePool<ProducerStatus>

A Pool of ProducerRunner

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 ProducerFactory<M>	factory
protected String	logName
protected LogManager	manager

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

nbThreads, supplyThreadPool, threadPool

Constructor Summary

Constructors

Constructor and Description
ProducerPool(String logName, LogManager manager, ProducerFactory<M> factory, short nbThreads)

Method Summary

Modifier and Type	Method and Description
protected void	afterCall(List<ProducerStatus> ret)
protected Callable<ProducerStatus>	getCallable(int i)
protected ProducerStatus	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 ProducerFactory<M extends Message> factory

logName

protected final String logName

Constructor Detail

ProducerPool

public ProducerPool(String logName,
                    LogManager manager,
                    ProducerFactory<M> factory,
                    short nbThreads)

Method Detail

getErrorStatus

protected ProducerStatus getErrorStatus()

Description copied from class: AbstractCallablePool

Value to return when there was an exception during execution

Specified by:

getErrorStatus in class AbstractCallablePool<ProducerStatus>

getCallable

protected Callable<ProducerStatus> getCallable(int i)

Specified by:

getCallable in class AbstractCallablePool<ProducerStatus>

getThreadPrefix

protected String getThreadPrefix()

Specified by:

getThreadPrefix in class AbstractCallablePool<ProducerStatus>

afterCall

protected void afterCall(List<ProducerStatus> ret)

Specified by:

afterCall in class AbstractCallablePool<ProducerStatus>