public class QueueImporter extends Object
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 and Description |
---|
QueueImporter(ImporterLogger log) |
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) |
protected ImporterLogger log
protected long processedNodesConsumer
protected long unprocessedNodesConsumer
protected long nbDocsCreated
protected volatile boolean isRunning
protected final ImportStat importStat
protected final List<ImporterFilter> filters
protected final List<Thread> consumerThreads
protected Thread producerThread
public QueueImporter(ImporterLogger log)
public void importDocuments(Producer producer, QueuesManager manager, String importPath, String repositoryName, int batchSize, ConsumerFactory factory)
protected void checkConsumerQueues(QueuesManager manager)
protected Exception waitForProducer(Producer producer)
protected boolean consumersTerminated(List<Consumer> consumers)
protected void startProducerThread(Producer producer)
public ImportStat getImportStat()
public void addFilter(ImporterFilter filter)
public long getCreatedDocsCounter()
protected void enableFilters()
protected void disableFilters(Exception finalException)
public boolean isRunning()
Copyright © 2016 Nuxeo SA. All rights reserved.