public class DocumentConsumerPool<M extends Message> extends ConsumerPool<M>
AbstractCallablePool.NamedThreadFactory
Modifier and Type | Field and Description |
---|---|
protected static String |
BINARY_LISTENER |
protected static String |
DUBLICORE_LISTENER |
protected static String |
INDEXING_LISTENER |
protected static String |
MIME_LISTENER |
protected static String |
NOTIF_LISTENER |
protected static String |
TPL_LISTENER |
protected static String |
UID_LISTENER |
Constructor and Description |
---|
DocumentConsumerPool(MQueues<M> qm,
ConsumerFactory<M> factory,
ConsumerPolicy policy) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
afterCall, getCallable, getErrorStatus, getThreadPrefix
runPool, start
protected static final String NOTIF_LISTENER
protected static final String MIME_LISTENER
protected static final String INDEXING_LISTENER
protected static final String DUBLICORE_LISTENER
protected static final String TPL_LISTENER
protected static final String BINARY_LISTENER
protected static final String UID_LISTENER
public DocumentConsumerPool(MQueues<M> qm, ConsumerFactory<M> factory, ConsumerPolicy policy)
public void close() throws Exception
close
in interface AutoCloseable
close
in class ConsumerPool<M extends Message>
Exception
Copyright © 2017 Nuxeo. All rights reserved.