Package 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

Field Summary

Fields

Modifier and Type	Field	Description
protected static String	BINARY_LISTENER
protected static String	BLOB_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	listenerBlobEnabled
protected boolean	listenerDublincoreEnabled
protected boolean	listenerIndexingEnabled
protected boolean	listenerMimeEnabled
protected boolean	listenerNotifEnabled
protected boolean	listenerPictureEnabled
protected boolean	listenerTplEnabled
protected boolean	listenerUidEnabled
protected boolean	listenerVideoEnabled
protected static String	MIME_LISTENER
protected static String	NOTIF_LISTENER
protected static String	PICTURE_LISTENER
protected DocumentConsumerPolicy	policy
protected static String	TPL_LISTENER
protected static String	UID_LISTENER
protected static String	VIDEO_LISTENER

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

Constructors

Constructor	Description
DocumentConsumerPool(String logName, LogManager manager, Codec<M> codec, ConsumerFactory<M> factory, ConsumerPolicy consumerPolicy)
DocumentConsumerPool(String logName, LogManager manager, ConsumerFactory<M> factory, ConsumerPolicy consumerPolicy)	Deprecated. since 11.1, due to serialization issue with java 11, use DocumentConsumerPool(String, LogManager, Codec, ConsumerFactory, ConsumerPolicy) which allows to give a codec to tailer.

Method Summary

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

VIDEO_LISTENER

protected static final String VIDEO_LISTENER

See Also:

Constant Field Values

PICTURE_LISTENER

protected static final String PICTURE_LISTENER

See Also:

Constant Field Values

BLOB_LISTENER

protected static final String BLOB_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

listenerVideoEnabled

protected boolean listenerVideoEnabled

listenerPictureEnabled

protected boolean listenerPictureEnabled

listenerBlobEnabled

protected boolean listenerBlobEnabled

Constructor Detail

DocumentConsumerPool

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

Deprecated.

since 11.1, due to serialization issue with java 11, use DocumentConsumerPool(String, LogManager, Codec, ConsumerFactory, ConsumerPolicy) which allows to give a codec to tailer.

DocumentConsumerPool

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

Method Detail

disableSyncListener

protected boolean disableSyncListener(EventServiceAdmin eventAdmin,
                                      String name)

close

public void close()

Specified by:

close in interface AutoCloseable

Overrides:

close in class AbstractCallablePool<ConsumerStatus>