Package com.adaptris.core.fs
Class MovingNonDeletingFsConsumer
- java.lang.Object
-
- com.adaptris.core.AdaptrisMessageWorkerImp
-
- com.adaptris.core.AdaptrisMessageConsumerImp
-
- com.adaptris.core.AdaptrisPollingConsumer
-
- com.adaptris.core.fs.FsConsumerImpl
-
- com.adaptris.core.fs.NonDeletingFsConsumer
-
- com.adaptris.core.fs.MovingNonDeletingFsConsumer
-
- All Implemented Interfaces:
AdaptrisComponent
,AdaptrisMessageConsumer
,AdaptrisMessageWorker
,ComponentLifecycle
,ComponentLifecycleExtension
,MessageEventGenerator
,StateManagedComponent
@ComponentProfile(summary="Pickup messages from the filesystem and move them afterwards", tag="consumer,fs,filesystem", metadata={"originalname","fsFileSize","lastmodified","fsConsumeDir","_interlokMessageConsumedFrom","fsParentDir"}, recommended=NullConnection.class) public class MovingNonDeletingFsConsumer extends NonDeletingFsConsumer
Extends the non-deleting FS consumer, and after processing stores files in a separate directory. This is similar to the FTP consumer. ../../../...
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class com.adaptris.core.AdaptrisPollingConsumer
AdaptrisPollingConsumer.LockOperator
-
-
Field Summary
-
Fields inherited from class com.adaptris.core.fs.FsConsumerImpl
fileFilter, fsWorker
-
Fields inherited from class com.adaptris.core.AdaptrisMessageWorkerImp
log
-
-
Constructor Summary
Constructors Constructor Description MovingNonDeletingFsConsumer()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.String
getProcessedPath()
Get the path where processed files are placed once done with.protected int
processFile(java.io.File file)
Attempt to process this file which might be a directory.void
setProcessedPath(java.lang.String s)
Set where processed file are placed once done with.-
Methods inherited from class com.adaptris.core.fs.NonDeletingFsConsumer
close, getProcessedItemCache, hasChanged, init, processMessages, setProcessedItemCache, start, stop
-
Methods inherited from class com.adaptris.core.fs.FsConsumerImpl
addStandardMetadata, baseDirUrl, checkModified, consumeLocationKey, createAdaptrisMessage, filterExpression, getBaseDirectoryUrl, getCreateDirs, getFileFilterImp, getFileSorter, getFilterExpression, getLogAllExceptions, getQuietInterval, isFileAccessible, logAllExceptions, prepareConsumer, setBaseDirectoryUrl, setCreateDirs, setFileFilterImp, setFileSorter, setFilterExpression, setLogAllExceptions, setQuietInterval, shouldCreateDirs, verifyDirectory, withBaseDirectoryUrl, withFilterExpression
-
Methods inherited from class com.adaptris.core.AdaptrisPollingConsumer
continueProcessingMessages, getMaxMessagesPerPoll, getPoller, getReacquireLockBetweenMessages, prepare, releaseLock, setMaxMessagesPerPoll, setPoller, setReacquireLockBetweenMessages
-
Methods inherited from class com.adaptris.core.AdaptrisMessageConsumerImp
changeState, newThreadName, registerAdaptrisMessageListener, renameThread, requestClose, requestInit, requestStart, requestStop, retrieveAdaptrisMessageListener, retrieveComponentState
-
Methods inherited from class com.adaptris.core.AdaptrisMessageWorkerImp
createName, createQualifier, decode, encode, getEncoder, getIsTrackingEndpoint, getMessageFactory, getUniqueId, handleConnectionException, isTrackingEndpoint, registerConnection, registerEncoderMessageFactory, retrieveConnection, setEncoder, setIsTrackingEndpoint, setMessageFactory, setUniqueId, withMessageFactory, withUniqueID
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface com.adaptris.core.AdaptrisComponent
getUniqueId
-
Methods inherited from interface com.adaptris.core.AdaptrisMessageWorker
decode, encode, getEncoder, getMessageFactory, handleConnectionException, registerConnection, retrieveConnection, setEncoder, setMessageFactory
-
Methods inherited from interface com.adaptris.core.MessageEventGenerator
createName, createQualifier, isTrackingEndpoint
-
-
-
-
Method Detail
-
processFile
protected int processFile(java.io.File file) throws CoreException
Attempt to process this file which might be a directory..- Overrides:
processFile
in classNonDeletingFsConsumer
- Parameters:
file
- the File- Returns:
- the number of files processed.
- Throws:
CoreException
- wrapping any other Exception.
-
setProcessedPath
public void setProcessedPath(java.lang.String s)
Set where processed file are placed once done with.- Parameters:
s
- Set the processed path.
-
getProcessedPath
public java.lang.String getProcessedPath()
Get the path where processed files are placed once done with.- Returns:
- Get the processed path.
-
-