org.ikasan.connector.basefiletransfer.outbound.command

Class FileDiscoveryCommand

java.lang.Object

org.ikasan.connector.base.command.AbstractTransactionalResourceCommand

org.ikasan.connector.basefiletransfer.outbound.command.AbstractBaseFileTransferTransactionalResourceCommand

org.ikasan.connector.basefiletransfer.outbound.command.FileDiscoveryCommand

All Implemented Interfaces:

TransactionalResourceCommand, TransactionCommitFailureObserverable

public class FileDiscoveryCommand
extends AbstractBaseFileTransferTransactionalResourceCommand

Discovers new files from a remote browsable directory

Author:

Ikasan Development Team

Field Summary

Fields inherited from class org.ikasan.connector.basefiletransfer.outbound.command.AbstractBaseFileTransferTransactionalResourceCommand

CURRENT_DIRECTORY, EOL, fileSeparator, listeners

Fields inherited from class org.ikasan.connector.base.command.AbstractTransactionalResourceCommand

COMMIT_IN_PROGRESS, COMPLETED_COMMITTING, EXECUTED_STATE, EXECUTION_IN_PROGRESS, executionContext, INITIALISED_STATE, ROLLBACK_IN_PROGRESS, ROLLED_BACK_STATE, transactionalResource

Constructor Summary

Constructors

Constructor and Description
FileDiscoveryCommand() No args constructor as required by Hibernate
FileDiscoveryCommand(String sourceDirectory, String filenamePattern, BaseFileTransferDao persistence, long minAge, boolean filterDuplicates, boolean filterOnFilename, boolean filterOnLastModifiedDate, boolean isRecursive) Constructor

Method Summary

Methods

Modifier and Type	Method and Description
protected void	doCommit()
protected void	doRollback()
protected List<ClientListEntry>	listDirectory(String directory, List<ClientListEntry> allFiles)
protected ExecutionOutput	performExecute() execute method for subclasses to implement
String	toString()

Methods inherited from class org.ikasan.connector.basefiletransfer.outbound.command.AbstractBaseFileTransferTransactionalResourceCommand

addListener, changeDirectory, deleteDir, deleteFile, doExecute, findFile, getClient, getContentAsStream, getFile, getFile, listDirectory, logFileList, notifyListeners, printWorkingDirectoryName, putFile, putWithOutputStream, renameFile

Methods inherited from class org.ikasan.connector.base.command.AbstractTransactionalResourceCommand

commit, execute, getBeanFactory, getExecutionTimestamp, getId, getState, getXid, rollback, setBeanFactory, setExecutionContext, setTransactionalResource, setTransactionJournal, setXid

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

FileDiscoveryCommand

public FileDiscoveryCommand()

No args constructor as required by Hibernate

FileDiscoveryCommand

public FileDiscoveryCommand(String sourceDirectory,
                    String filenamePattern,
                    BaseFileTransferDao persistence,
                    long minAge,
                    boolean filterDuplicates,
                    boolean filterOnFilename,
                    boolean filterOnLastModifiedDate,
                    boolean isRecursive)

Constructor

Parameters:

sourceDirectory - The directory we're picking up the file from

filenamePattern - The pattern to search for

persistence - The DAO persistence class

minAge - The minimum age of the file

filterDuplicates - Whether we filter duplicates

filterOnFilename - Whether we filter on file name

filterOnLastModifiedDate - Whether we filter on the last modified date

Method Detail

doCommit

protected void doCommit()

Specified by:

doCommit in class AbstractTransactionalResourceCommand

performExecute

protected ExecutionOutput performExecute()
                                  throws javax.resource.ResourceException

Description copied from class: AbstractBaseFileTransferTransactionalResourceCommand

execute method for subclasses to implement

Specified by:

performExecute in class AbstractBaseFileTransferTransactionalResourceCommand

Returns:

ExecutionOutput

Throws:

javax.resource.ResourceException - -

doRollback

protected void doRollback()

Specified by:

doRollback in class AbstractTransactionalResourceCommand

listDirectory

protected List<ClientListEntry> listDirectory(String directory,
                                  List<ClientListEntry> allFiles)
                                       throws javax.resource.ResourceException

Throws:

javax.resource.ResourceException

toString

public String toString()

Overrides:

toString in class Object

See Also:

Object.toString()