Package com.logicaldoc.importfolder
Class ImportFolderCrawler
java.lang.Object
com.logicaldoc.core.task.Task
com.logicaldoc.importfolder.ImportFolderCrawler
- All Implemented Interfaces:
Runnable
public class ImportFolderCrawler
extends com.logicaldoc.core.task.Task
This component crawls all remote import folders importing found files in the
dms.
- Since:
- 2.1
- Author:
- Marco Meschieri- LogicalDOC
-
Field Summary
FieldsFields inherited from class com.logicaldoc.core.task.Task
STATUS_IDLE, STATUS_RUNNING, STATUS_STOPPING -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid_next()voidafterDocumentImported(ImportFolder importFolder, com.logicaldoc.core.document.Document document, String originalPath, boolean newFile) To be invoked after a file has been importedstatic voidbeforeDocumentImported(ImportFolder importFolder, com.logicaldoc.core.document.AbstractDocument document, String originalPath, com.logicaldoc.core.document.DocumentHistory transaction) To be invoked before a file gets importedvoidDownloads all new files from all import folders.com.logicaldoc.core.document.dao.DocumentDAOlonglongintorg.slf4j.LoggergetLog()intlongbooleanbooleanvoidonError(ImportFolder importFolder, com.logicaldoc.core.document.Document document, String originalPath, Throwable error) To be invoked after an error has been detectedvoidsetCacheManager(ImportFolderCacheManager cacheManager) voidsetDefaultOwner(String defaultOwner) voidsetDocumentDao(com.logicaldoc.core.document.dao.DocumentDAO documentDao) voidsetImportFolderDao(ImportFolderDAO importFolderDao) voidsetImportFolderHistoryDao(ImportFolderHistoryDAO importFolderHistoryDao) voidsetSequenceDao(com.logicaldoc.core.sequence.SequenceDAO sequenceDao) Methods inherited from class com.logicaldoc.core.task.Task
addTaskListener, getCompletionPercentage, getConfig, getName, getProgress, getReportRecipients, getScheduling, getSize, getStatus, interrupt, isInterrupted, isInterruptRequested, isRunning, isSendActivityReport, notifyReport, removeTaskListener, run, save, saveWork, setConfig, setLockManager, setReportRecipients, setSendActivityReport, setSender, setSize, setSystemLoadMonitor, setUserDao
-
Field Details
-
NAME
- See Also:
-
COUNTER_SEQUENCE
- See Also:
-
-
Constructor Details
-
ImportFolderCrawler
public ImportFolderCrawler()
-
-
Method Details
-
getCacheManager
-
setCacheManager
-
getDocumentDao
public com.logicaldoc.core.document.dao.DocumentDAO getDocumentDao() -
setDocumentDao
public void setDocumentDao(com.logicaldoc.core.document.dao.DocumentDAO documentDao) -
crawlImportFolders
public void crawlImportFolders()Downloads all new files from all import folders. The stored document will be owned by the specified default owner -
beforeDocumentImported
public static void beforeDocumentImported(ImportFolder importFolder, com.logicaldoc.core.document.AbstractDocument document, String originalPath, com.logicaldoc.core.document.DocumentHistory transaction) To be invoked before a file gets imported- Parameters:
importFolder- the used import folderdocument- the target created / updated documentoriginalPath- the original path of the filetransaction- the current event
-
afterDocumentImported
public void afterDocumentImported(ImportFolder importFolder, com.logicaldoc.core.document.Document document, String originalPath, boolean newFile) To be invoked after a file has been imported- Parameters:
importFolder- the used import folderdocument- the target created / updated documentoriginalPath- the original path of the filenewFile- if this is a new import or an update
-
onError
public void onError(ImportFolder importFolder, com.logicaldoc.core.document.Document document, String originalPath, Throwable error) To be invoked after an error has been detected- Parameters:
importFolder- the used import folderdocument- the target documentoriginalPath- the original path of the fileerror- the exception generated by the error
-
isIndeterminate
public boolean isIndeterminate()- Specified by:
isIndeterminatein classcom.logicaldoc.core.task.Task
-
isConcurrent
public boolean isConcurrent()- Specified by:
isConcurrentin classcom.logicaldoc.core.task.Task
-
setDefaultOwner
-
getRemoteCount
public int getRemoteCount() -
getLocalCount
public int getLocalCount() -
getImported
public long getImported() -
getUpdated
public long getUpdated() -
getErrors
public long getErrors() -
getDefaultOwner
-
_next
public void _next() -
getLog
public org.slf4j.Logger getLog() -
getImportFolderDao
-
setImportFolderDao
-
setSequenceDao
public void setSequenceDao(com.logicaldoc.core.sequence.SequenceDAO sequenceDao) -
setImportFolderHistoryDao
-