public class DefaultConsumer extends AbstractConsumer
Modifier and Type | Field and Description |
---|---|
protected FileManager |
fileManager |
protected String |
rootPath |
batch, CHECK_INTERVAL, commitTimer, consumerCount, failCount, lastCheckTime, lastCommitTime, lastCount, lastImediatThroughput, log, originatingUsername, processTimer, queue, queuesManager, registry, replayMode, repositoryName, retryCount, rootRef, startTime, threadName, TRANSACTION_THRESOLD_MS
canStop, completed, error, mustStop, nbProcessed, started
Constructor and Description |
---|
DefaultConsumer(ImporterLogger log,
DocumentModel root,
int batchSize,
QueuesManager queuesManager,
int queue) |
Modifier and Type | Method and Description |
---|---|
double |
getNbDocsCreated() |
protected String |
getType() |
protected void |
process(CoreSession session,
SourceNode src) |
protected DocumentModel |
setDocumentProperties(CoreSession session,
Map<String,Serializable> properties,
DocumentModel doc) |
commit, commitIfNeeded, getOriginatingUsername, onSourceNodeException, onSourceNodeRollBack, rollbackAndReplayBatch, run, runDrainer, runImport, setOriginatingUsername
canStop, getError, getNbProcessed, incrementProcessed, isCompleted, isTerminated, mustStop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
canStop, getError, getNbProcessed, isCompleted, isTerminated, mustStop
protected final FileManager fileManager
public DefaultConsumer(ImporterLogger log, DocumentModel root, int batchSize, QueuesManager queuesManager, int queue)
protected void process(CoreSession session, SourceNode src) throws IOException
process
in class AbstractConsumer
IOException
protected DocumentModel setDocumentProperties(CoreSession session, Map<String,Serializable> properties, DocumentModel doc)
public double getNbDocsCreated()
Copyright © 2017 Nuxeo. All rights reserved.