org.nuxeo.ecm.platform.importer.queue.consumer

Class DefaultConsumer

java.lang.Object

org.nuxeo.ecm.platform.importer.queue.AbstractTaskRunner

org.nuxeo.ecm.platform.importer.queue.consumer.AbstractConsumer

org.nuxeo.ecm.platform.importer.queue.consumer.DefaultConsumer

All Implemented Interfaces:

Runnable, Consumer, TaskRunner

public class DefaultConsumer
extends AbstractConsumer

Since:

8.3

Field Summary

Fields

Modifier and Type	Field and Description
protected FileManager	fileManager
protected String	rootPath

Fields inherited from class org.nuxeo.ecm.platform.importer.queue.consumer.AbstractConsumer

batch, CHECK_INTERVAL, commitTimer, consumerCount, failCount, lastCheckTime, lastCount, lastImediatThroughput, log, originatingUsername, processTimer, queue, registry, replayMode, repositoryName, retryCount, rootRef, startTime, threadName

Fields inherited from class org.nuxeo.ecm.platform.importer.queue.AbstractTaskRunner

canStop, completed, error, mustStop, nbProcessed, started

Constructor Summary

Constructors

Constructor and Description
DefaultConsumer(ImporterLogger log, DocumentModel root, int batchSize, BlockingQueue<SourceNode> queue)

Method Summary

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)

Methods inherited from class org.nuxeo.ecm.platform.importer.queue.consumer.AbstractConsumer

commit, commitIfNeeded, getOriginatingUsername, onSourceNodeException, onSourceNodeRollBack, rollbackAndReplayBatch, run, runDrainer, runImport, setOriginatingUsername

Methods inherited from class org.nuxeo.ecm.platform.importer.queue.AbstractTaskRunner

canStop, getError, getNbProcessed, incrementProcessed, isCompleted, isTerminated, mustStop

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.nuxeo.ecm.platform.importer.queue.TaskRunner

canStop, getError, getNbProcessed, isCompleted, isTerminated, mustStop

Field Detail

fileManager

protected final FileManager fileManager

rootPath

protected final String rootPath

Constructor Detail

DefaultConsumer

public DefaultConsumer(ImporterLogger log,
                       DocumentModel root,
                       int batchSize,
                       BlockingQueue<SourceNode> queue)

Method Detail

getType

protected String getType()

process

protected void process(CoreSession session,
                       SourceNode src)
                throws IOException

Specified by:

process in class AbstractConsumer

Throws:

IOException

setDocumentProperties

protected DocumentModel setDocumentProperties(CoreSession session,
                                              Map<String,Serializable> properties,
                                              DocumentModel doc)

getNbDocsCreated

public double getNbDocsCreated()