Package org.nuxeo.importer.stream.automation

Class DocumentConsumers

java.lang.Object

org.nuxeo.importer.stream.automation.DocumentConsumers

public class DocumentConsumers
extends Object

Since:

9.1

Field Summary

Fields

Modifier and Type	Field	Description
protected Integer	batchSize
protected Integer	batchThresholdS
protected Boolean	blockAsyncListeners
protected Boolean	blockIndexing
protected Boolean	blockPostCommitListeners
protected Boolean	blockSyncListeners
protected OperationContext	ctx
static String	ID
protected String	logName
protected Integer	nbThreads
protected String	repositoryName
protected Integer	retryDelayS
protected Integer	retryMax
protected String	rootFolder
protected Boolean	useBulkMode
protected Integer	waitMessageTimeoutSeconds

Constructor Summary

Constructors

Constructor	Description
DocumentConsumers()

Method Summary

Modifier and Type	Method	Description
protected short	getNbThreads()
protected String	getRepositoryName()
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

ID

public static final String ID

See Also:

Constant Field Values

ctx

protected OperationContext ctx

nbThreads

protected Integer nbThreads

rootFolder

protected String rootFolder

repositoryName

protected String repositoryName

batchSize

protected Integer batchSize

batchThresholdS

protected Integer batchThresholdS

retryMax

protected Integer retryMax

retryDelayS

protected Integer retryDelayS

logName

protected String logName

blockIndexing

protected Boolean blockIndexing

blockAsyncListeners

protected Boolean blockAsyncListeners

blockPostCommitListeners

protected Boolean blockPostCommitListeners

blockSyncListeners

protected Boolean blockSyncListeners

useBulkMode

protected Boolean useBulkMode

waitMessageTimeoutSeconds

protected Integer waitMessageTimeoutSeconds

Constructor Detail

DocumentConsumers

public DocumentConsumers()

Method Detail

run

public void run()
         throws OperationException

Throws:

OperationException

getNbThreads

protected short getNbThreads()

getRepositoryName

protected String getRepositoryName()