org.nuxeo.ecm.platform.importer.queue

Class QueueImporter

java.lang.Object

org.nuxeo.ecm.platform.importer.queue.QueueImporter

public class QueueImporter
extends Object

Since:

8.3

Field Summary

Fields

Modifier and Type	Field and Description
protected List<Thread>	consumerThreads
protected List<ImporterFilter>	filters
protected ImportStat	importStat
protected boolean	isRunning
protected ImporterLogger	log
protected long	nbDocsCreated
protected long	processedNodesConsumer
protected Thread	producerThread
protected long	unprocessedNodesConsumer

Constructor Summary

Constructors

Constructor and Description
QueueImporter(ImporterLogger log)

Method Summary

Modifier and Type	Method and Description
void	addFilter(ImporterFilter filter)
protected void	checkConsumerQueues(QueuesManager manager)
protected boolean	consumersTerminated(List<Consumer> consumers)
protected void	disableFilters(Exception finalException)
protected void	enableFilters()
long	getCreatedDocsCounter()
ImportStat	getImportStat()
void	importDocuments(Producer producer, QueuesManager manager, String importPath, String repositoryName, int batchSize, ConsumerFactory factory)
boolean	isRunning()
protected void	startProducerThread(Producer producer)
protected Exception	waitForProducer(Producer producer)

Methods inherited from class java.lang.Object

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

Field Detail

log

protected ImporterLogger log

processedNodesConsumer

protected long processedNodesConsumer

unprocessedNodesConsumer

protected long unprocessedNodesConsumer

nbDocsCreated

protected long nbDocsCreated

isRunning

protected volatile boolean isRunning

importStat

protected final ImportStat importStat

filters

protected final List<ImporterFilter> filters

consumerThreads

protected final List<Thread> consumerThreads

producerThread

protected Thread producerThread

Constructor Detail

QueueImporter

public QueueImporter(ImporterLogger log)

Method Detail

importDocuments

public void importDocuments(Producer producer,
                            QueuesManager manager,
                            String importPath,
                            String repositoryName,
                            int batchSize,
                            ConsumerFactory factory)

checkConsumerQueues

protected void checkConsumerQueues(QueuesManager manager)

waitForProducer

protected Exception waitForProducer(Producer producer)

consumersTerminated

protected boolean consumersTerminated(List<Consumer> consumers)

startProducerThread

protected void startProducerThread(Producer producer)

getImportStat

public ImportStat getImportStat()

addFilter

public void addFilter(ImporterFilter filter)

getCreatedDocsCounter

public long getCreatedDocsCounter()

enableFilters

protected void enableFilters()

disableFilters

protected void disableFilters(Exception finalException)

isRunning

public boolean isRunning()