org.nuxeo.importer.stream.consumer

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

public class DocumentConsumerPool<M extends Message>
extends ConsumerPool<M>

Consumer Pool that block Nuxeo listeners during import.

Since:

9.1

Nested Class Summary

Nested classes/interfaces inherited from class org.nuxeo.lib.stream.pattern.consumer.internals.AbstractCallablePool

AbstractCallablePool.NamedThreadFactory

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	BINARY_LISTENER
protected boolean	blockAsync
protected boolean	blockPostCommit
protected boolean	bulkMode
protected static String	DUBLICORE_LISTENER
protected static String	INDEXING_LISTENER
protected boolean	listenerBinaryEnabled
protected boolean	listenerDublincoreEnabled
protected boolean	listenerIndexingEnabled
protected boolean	listenerMimeEnabled
protected boolean	listenerNotifEnabled
protected boolean	listenerTplEnabled
protected boolean	listenerUidEnabled
protected static String	MIME_LISTENER
protected static String	NOTIF_LISTENER
protected DocumentConsumerPolicy	policy
protected static String	TPL_LISTENER
protected static String	UID_LISTENER

Fields inherited from class org.nuxeo.lib.stream.pattern.consumer.ConsumerPool

defaultAssignments, factory, logName, manager

Fields inherited from class org.nuxeo.lib.stream.pattern.consumer.internals.AbstractCallablePool

nbThreads, supplyThreadPool, threadPool

Constructor Summary

Constructors

Constructor and Description
DocumentConsumerPool(String logName, LogManager manager, ConsumerFactory<M> factory, ConsumerPolicy consumerPolicy)

Method Summary

Modifier and Type	Method and Description
void	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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

NOTIF_LISTENER

protected static final String NOTIF_LISTENER

See Also:

Constant Field Values

MIME_LISTENER

protected static final String MIME_LISTENER

See Also:

Constant Field Values

INDEXING_LISTENER

protected static final String INDEXING_LISTENER

See Also:

Constant Field Values

DUBLICORE_LISTENER

protected static final String DUBLICORE_LISTENER

See Also:

Constant Field Values

TPL_LISTENER

protected static final String TPL_LISTENER

See Also:

Constant Field Values

BINARY_LISTENER

protected static final String BINARY_LISTENER

See Also:

Constant Field Values

UID_LISTENER

protected static final String UID_LISTENER

See Also:

Constant Field Values

blockAsync

protected boolean blockAsync

policy

protected final DocumentConsumerPolicy 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

Constructor Detail

DocumentConsumerPool

public DocumentConsumerPool(String logName,
                            LogManager manager,
                            ConsumerFactory<M> factory,
                            ConsumerPolicy consumerPolicy)

Method Detail

disableSyncListener

protected boolean disableSyncListener(EventServiceAdmin eventAdmin,
                                      String name)

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Overrides:

close in class AbstractCallablePool<ConsumerStatus>

Throws:

Exception