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(List<Producer> producers,
QueuesManager manager,
String importPath,
String repositoryName,
int batchSize,
ConsumerFactory factory) |
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)
public void importDocuments(List<Producer> producers, 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 © 2017 Nuxeo. All rights reserved.