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","lastmodified","fsFileSize","fsConsumeDir","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

Fields inherited from interface com.adaptris.core.MessageEventGenerator

CONFIRMATION_ID_KEY

Constructor Summary

Constructors

Constructor and Description
MovingNonDeletingFsConsumer()
MovingNonDeletingFsConsumer(ConsumeDestination d)

Method Summary

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.

Methods inherited from class com.adaptris.core.fs.NonDeletingFsConsumer

close, getProcessedItemCache, hasChanged, init, prepareConsumer, processMessages, setProcessedItemCache, start, stop

Methods inherited from class com.adaptris.core.fs.FsConsumerImpl

addStandardMetadata, checkModified, createAdaptrisMessage, getCreateDirs, getFileFilterImp, getFileSorter, getLogAllExceptions, getQuietInterval, isFileAccessible, logAllExceptions, setCreateDirs, setFileFilterImp, setFileSorter, setLogAllExceptions, setQuietInterval, shouldCreateDirs, verifyDirectory

Methods inherited from class com.adaptris.core.AdaptrisPollingConsumer

continueProcessingMessages, continueProcessingMessages, getMaxMessagesPerPoll, getPoller, getReacquireLockBetweenMessages, prepare, releaseLock, setMaxMessagesPerPoll, setPoller, setReacquireLockBetweenMessages

Methods inherited from class com.adaptris.core.AdaptrisMessageConsumerImp

changeState, getDestination, registerAdaptrisMessageListener, renameThread, requestClose, requestInit, requestStart, requestStop, retrieveAdaptrisMessageListener, retrieveComponentState, setDestination

Methods inherited from class com.adaptris.core.AdaptrisMessageWorkerImp

createName, createQualifier, decode, encode, getEncoder, getIsConfirmation, getIsTrackingEndpoint, getMessageFactory, getUniqueId, handleConnectionException, isConfirmation, isTrackingEndpoint, registerConnection, registerEncoderMessageFactory, retrieveConnection, setEncoder, setIsConfirmation, setIsTrackingEndpoint, setMessageFactory, setUniqueId, withMessageFactory

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.AdaptrisMessageWorker

decode, encode, getEncoder, getMessageFactory, handleConnectionException, registerConnection, retrieveConnection, setEncoder, setMessageFactory

Methods inherited from interface com.adaptris.core.AdaptrisComponent

getUniqueId

Methods inherited from interface com.adaptris.core.MessageEventGenerator

createName, createQualifier, isConfirmation, isTrackingEndpoint

Constructor Detail

MovingNonDeletingFsConsumer

public MovingNonDeletingFsConsumer()

MovingNonDeletingFsConsumer

public MovingNonDeletingFsConsumer(ConsumeDestination d)

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 class NonDeletingFsConsumer

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.