public class ProducerPool<M extends Message> extends AbstractCallablePool<ProducerStatus>
AbstractCallablePool.NamedThreadFactory
Constructor and Description |
---|
ProducerPool(String mqName,
MQManager<M> 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
public ProducerPool(String mqName, MQManager<M> 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 © 2017 Nuxeo. All rights reserved.