public class ProducerPool<M extends Message> extends AbstractCallablePool<ProducerStatus>
AbstractCallablePool.NamedThreadFactory
Constructor and Description |
---|
ProducerPool(MQueues<M> mq,
ProducerFactory<M> factory,
int 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 excution
|
protected String |
getThreadPrefix() |
close, runPool, start
public ProducerPool(MQueues<M> mq, ProducerFactory<M> factory, int 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 © 2017 Nuxeo. All rights reserved.