public class DocumentConsumers extends Object
Modifier and Type | Field and 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 |
kafkaConfig |
protected String |
mqName |
protected Integer |
nbThreads |
protected String |
repositoryName |
protected Integer |
retryDelayS |
protected Integer |
retryMax |
protected String |
rootFolder |
protected Boolean |
useBulkMode |
Constructor and Description |
---|
DocumentConsumers() |
Modifier and Type | Method and Description |
---|---|
protected MQManager<DocumentMessage> |
getManager() |
protected String |
getMQName() |
protected String |
getRepositoryName() |
void |
run() |
public static final String ID
protected OperationContext ctx
protected String rootFolder
protected String repositoryName
protected Integer batchThresholdS
protected Integer retryDelayS
protected String kafkaConfig
protected Boolean blockIndexing
protected Boolean blockAsyncListeners
protected Boolean blockPostCommitListeners
protected Boolean blockSyncListeners
protected Boolean useBulkMode
public DocumentConsumers()
public void run()
protected String getRepositoryName()
protected MQManager<DocumentMessage> getManager()
Copyright © 2017 Nuxeo. All rights reserved.