org.nuxeo.ecm.platform.importer.base

Class GenericThreadedImportTask

java.lang.Object

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

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

CaseImporterThreadedTask

public class GenericThreadedImportTask
extends Object
implements Runnable

Generic importer task

Author:

Thierry Delprat

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)
void	dispose()
int	getBatchSize()
boolean	isRunning()
void	run()
void	setBatchSize(int batchSize)
void	setInputSource(SourceNode node)
void	setRootTask()
void	setSkipContainerCreation(Boolean skipContainerCreation)
void	setTargetFolder(DocumentModel rootDoc)

Methods inherited from class java.lang.Object

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

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

dispose

public void dispose()

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)