@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
AdaptrisPollingConsumer.LockOperator
fileFilter, fsWorker
log
Constructor and Description |
---|
MovingNonDeletingFsConsumer() |
Modifier and Type | Method and 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.
|
close, getProcessedItemCache, hasChanged, init, prepareConsumer, processMessages, setProcessedItemCache, start, stop
addStandardMetadata, baseDirUrl, checkModified, consumeLocationKey, createAdaptrisMessage, filterExpression, getBaseDirectoryUrl, getCreateDirs, getDestination, getFileFilterImp, getFileSorter, getFilterExpression, getLogAllExceptions, getQuietInterval, isFileAccessible, logAllExceptions, newThreadName, setBaseDirectoryUrl, setCreateDirs, setDestination, setFileFilterImp, setFileSorter, setFilterExpression, setLogAllExceptions, setQuietInterval, shouldCreateDirs, verifyDirectory, withBaseDirectoryUrl, withFilterExpression
continueProcessingMessages, getMaxMessagesPerPoll, getPoller, getReacquireLockBetweenMessages, prepare, releaseLock, setMaxMessagesPerPoll, setPoller, setReacquireLockBetweenMessages
changeState, registerAdaptrisMessageListener, renameThread, requestClose, requestInit, requestStart, requestStop, retrieveAdaptrisMessageListener, retrieveComponentState
createName, createQualifier, decode, encode, getEncoder, getIsTrackingEndpoint, getMessageFactory, getUniqueId, handleConnectionException, isTrackingEndpoint, registerConnection, registerEncoderMessageFactory, retrieveConnection, setEncoder, setIsTrackingEndpoint, setMessageFactory, setUniqueId, withMessageFactory, withUniqueID
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
decode, encode, getEncoder, getMessageFactory, handleConnectionException, registerConnection, retrieveConnection, setEncoder, setMessageFactory
getUniqueId
createName, createQualifier, isTrackingEndpoint
protected int processFile(java.io.File file) throws CoreException
processFile
in class NonDeletingFsConsumer
file
- the FileCoreException
- wrapping any other Exception.public void setProcessedPath(java.lang.String s)
s
- Set the processed path.public java.lang.String getProcessedPath()