public class ProducerPool<M extends Message> extends AbstractCallablePool<ProducerStatus>
AbstractCallablePool.NamedThreadFactory
Modifier and Type | Field and Description |
---|---|
protected ProducerFactory<M> |
factory |
protected String |
logName |
protected LogManager |
manager |
nbThreads, supplyThreadPool, threadPool
Constructor and Description |
---|
ProducerPool(String logName,
LogManager manager,
ProducerFactory<M> factory,
short nbThreads) |
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() |
close, getNbThreads, runPool, start
protected final LogManager manager
protected final ProducerFactory<M extends Message> factory
public ProducerPool(String logName, LogManager manager, ProducerFactory<M> factory, short nbThreads)
protected ProducerStatus getErrorStatus()
AbstractCallablePool
getErrorStatus
in class AbstractCallablePool<ProducerStatus>
protected Callable<ProducerStatus> getCallable(int i)
getCallable
in class AbstractCallablePool<ProducerStatus>
protected String getThreadPrefix()
getThreadPrefix
in class AbstractCallablePool<ProducerStatus>
protected void afterCall(List<ProducerStatus> ret)
afterCall
in class AbstractCallablePool<ProducerStatus>
Copyright © 2018 Nuxeo. All rights reserved.