public class QueueImporter extends Object
Modifier and Type | Field and Description |
---|---|
protected List<ImporterFilter> |
filters |
protected ImportStat |
importStat |
protected ImporterLogger |
log |
protected long |
nbDocsCreated |
protected long |
processedNodesConsumer |
Constructor and Description |
---|
QueueImporter(ImporterLogger log) |
Modifier and Type | Method and Description |
---|---|
void |
addFilter(ImporterFilter filter) |
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() |
void |
mustStop() |
protected ImporterLogger log
protected long processedNodesConsumer
protected ImportStat importStat
protected long nbDocsCreated
protected List<ImporterFilter> filters
public QueueImporter(ImporterLogger log)
public void mustStop()
public void importDocuments(Producer producer, QueuesManager manager, String importPath, String repositoryName, int batchSize, ConsumerFactory factory)
public ImportStat getImportStat()
public void addFilter(ImporterFilter filter)
public boolean isRunning()
public long getCreatedDocsCounter()
protected void enableFilters()
protected void disableFilters(Exception finalException)
Copyright © 2016 Nuxeo SA. All rights reserved.