Class DocumentConsumerPool<M extends Message>
java.lang.Object
org.nuxeo.lib.stream.pattern.consumer.internals.AbstractCallablePool<ConsumerStatus>
org.nuxeo.lib.stream.pattern.consumer.ConsumerPool<M>
org.nuxeo.importer.stream.consumer.DocumentConsumerPool<M>
- All Implemented Interfaces:
AutoCloseable
Consumer Pool that block Nuxeo listeners during import.
- Since:
- 9.1
-
Field Summary
Modifier and TypeFieldDescriptionprotected static final String
protected static final String
protected boolean
protected boolean
protected boolean
protected static final String
protected static final String
protected boolean
protected boolean
protected boolean
protected boolean
protected boolean
protected boolean
protected boolean
protected boolean
protected boolean
protected boolean
protected static final String
protected static final String
protected static final String
protected final DocumentConsumerPolicy
protected static final String
protected static final String
protected static final String
Fields inherited from class org.nuxeo.lib.stream.pattern.consumer.ConsumerPool
codec, defaultAssignments, factory, logName, manager
Fields inherited from class org.nuxeo.lib.stream.pattern.consumer.internals.AbstractCallablePool
nbThreads, supplyThreadPool, threadPool
-
Constructor Summary
ConstructorDescriptionDocumentConsumerPool
(String logName, LogManager manager, Codec<M> codec, ConsumerFactory<M> factory, ConsumerPolicy consumerPolicy) DocumentConsumerPool
(String logName, LogManager manager, ConsumerFactory<M> factory, ConsumerPolicy consumerPolicy) Deprecated. -
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
protected boolean
disableSyncListener
(EventServiceAdmin eventAdmin, String name) Methods inherited from class org.nuxeo.lib.stream.pattern.consumer.ConsumerPool
afterCall, computeNbThreads, getCallable, getConsumerGroupName, getDefaultAssignments, getErrorStatus, getThreadPrefix
Methods inherited from class org.nuxeo.lib.stream.pattern.consumer.internals.AbstractCallablePool
getNbThreads, runPool, start
-
Field Details
-
NOTIF_LISTENER
- See Also:
-
MIME_LISTENER
- See Also:
-
INDEXING_LISTENER
- See Also:
-
DUBLICORE_LISTENER
- See Also:
-
TPL_LISTENER
- See Also:
-
BINARY_LISTENER
- See Also:
-
UID_LISTENER
- See Also:
-
VIDEO_LISTENER
- See Also:
-
PICTURE_LISTENER
- See Also:
-
BLOB_LISTENER
- See Also:
-
blockAsync
protected boolean blockAsync -
policy
-
blockPostCommit
protected boolean blockPostCommit -
bulkMode
protected boolean bulkMode -
listenerIndexingEnabled
protected boolean listenerIndexingEnabled -
listenerNotifEnabled
protected boolean listenerNotifEnabled -
listenerMimeEnabled
protected boolean listenerMimeEnabled -
listenerDublincoreEnabled
protected boolean listenerDublincoreEnabled -
listenerTplEnabled
protected boolean listenerTplEnabled -
listenerBinaryEnabled
protected boolean listenerBinaryEnabled -
listenerUidEnabled
protected boolean listenerUidEnabled -
listenerVideoEnabled
protected boolean listenerVideoEnabled -
listenerPictureEnabled
protected boolean listenerPictureEnabled -
listenerBlobEnabled
protected boolean listenerBlobEnabled
-
-
Constructor Details
-
DocumentConsumerPool
@Deprecated public DocumentConsumerPool(String logName, LogManager manager, ConsumerFactory<M> factory, ConsumerPolicy consumerPolicy) Deprecated.since 11.1, due to serialization issue with java 11, useDocumentConsumerPool(String, LogManager, Codec, ConsumerFactory, ConsumerPolicy)
which allows to give acodec
totailer
. -
DocumentConsumerPool
public DocumentConsumerPool(String logName, LogManager manager, Codec<M> codec, ConsumerFactory<M> factory, ConsumerPolicy consumerPolicy)
-
-
Method Details
-
disableSyncListener
-
close
public void close()- Specified by:
close
in interfaceAutoCloseable
- Overrides:
close
in classAbstractCallablePool<ConsumerStatus>
-
DocumentConsumerPool(String, LogManager, Codec, ConsumerFactory, ConsumerPolicy)
which allows to give acodec
totailer
.