public class DefaultConsumer extends AbstractConsumer
Modifier and Type | Field and Description |
---|---|
protected FileManager |
fileManager |
protected String |
rootPath |
batch, CHECK_INTERVAL, importStat, lastCheckTime, lastCount, lastImediatThroughput, log, originatingUsername, queue, repositoryName, rootRef, startTime
canStop, completed, error, mustStop, nbProcessed, started
Constructor and Description |
---|
DefaultConsumer(ImporterLogger log,
DocumentModel root,
int batchSize,
BlockingQueue<SourceNode> 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, getImmediateThroughput, getImportStat, getOriginatingUsername, getThroughput, onSourceNodeException, onSourceNodeRollBack, run, 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 FileManager fileManager
public DefaultConsumer(ImporterLogger log, DocumentModel root, int batchSize, BlockingQueue<SourceNode> 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) throws ClientException
ClientException
public double getNbDocsCreated()
Copyright © 2016 Nuxeo SA. All rights reserved.