org.nuxeo.ecm.platform.importer.base

Class GenericThreadedImportTask

java.lang.Object

org.nuxeo.ecm.platform.importer.base.GenericThreadedImportTask

All Implemented Interfaces:

Runnable

public class GenericThreadedImportTask
extends Object
implements Runnable

Generic importer task

Author:

Thierry Delprat

Field Summary

Fields

Modifier and Type	Field and Description
static int	TX_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
GenericThreadedImportTask(CoreSession session, SourceNode rootSource, DocumentModel rootDoc, boolean skipContainerCreation, ImporterLogger rsLogger, int batchSize, ImporterDocumentModelFactory factory, ImporterThreadingPolicy threadPolicy)
GenericThreadedImportTask(CoreSession session, SourceNode rootSource, DocumentModel rootDoc, boolean skipContainerCreation, ImporterLogger rsLogger, int batchSize, ImporterDocumentModelFactory factory, ImporterThreadingPolicy threadPolicy, String jobName)

Method Summary

Methods

Modifier and Type	Method and Description
void	addImportingDocumentFilters(Collection<ImportingDocumentFilter> importingDocumentFilters)
void	addImportingDocumentFilters(ImportingDocumentFilter... importingDocumentFilters)
void	addListeners(Collection<ImporterListener> listeners)
void	addListeners(ImporterListener... listeners)
int	getBatchSize()
boolean	isRunning()
void	run()
void	setBatchSize(int batchSize)
void	setInputSource(SourceNode node)
void	setRootTask()
void	setSkipContainerCreation(Boolean skipContainerCreation)
void	setTargetFolder(DocumentModel rootDoc)
void	setTransactionTimeout(int transactionTimeout)

Methods inherited from class java.lang.Object

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

Field Detail

TX_TIMEOUT

public static final int TX_TIMEOUT

See Also:

Constant Field Values

Constructor Detail

GenericThreadedImportTask

public GenericThreadedImportTask(CoreSession session,
                         SourceNode rootSource,
                         DocumentModel rootDoc,
                         boolean skipContainerCreation,
                         ImporterLogger rsLogger,
                         int batchSize,
                         ImporterDocumentModelFactory factory,
                         ImporterThreadingPolicy threadPolicy)
                          throws Exception

Throws:

Exception

GenericThreadedImportTask

public GenericThreadedImportTask(CoreSession session,
                         SourceNode rootSource,
                         DocumentModel rootDoc,
                         boolean skipContainerCreation,
                         ImporterLogger rsLogger,
                         int batchSize,
                         ImporterDocumentModelFactory factory,
                         ImporterThreadingPolicy threadPolicy,
                         String jobName)
                          throws Exception

Throws:

Exception

Method Detail

setInputSource

public void setInputSource(SourceNode node)

setTargetFolder

public void setTargetFolder(DocumentModel rootDoc)

isRunning

public boolean isRunning()

run

public void run()

Specified by:

run in interface Runnable

getBatchSize

public int getBatchSize()

setBatchSize

public void setBatchSize(int batchSize)

setSkipContainerCreation

public void setSkipContainerCreation(Boolean skipContainerCreation)

setRootTask

public void setRootTask()

addImportingDocumentFilters

public void addImportingDocumentFilters(ImportingDocumentFilter... importingDocumentFilters)

addImportingDocumentFilters

public void addImportingDocumentFilters(Collection<ImportingDocumentFilter> importingDocumentFilters)

addListeners

public void addListeners(ImporterListener... listeners)

addListeners

public void addListeners(Collection<ImporterListener> listeners)

setTransactionTimeout

public void setTransactionTimeout(int transactionTimeout)