Package 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:

org.ikasan.connector.base.command.TransactionalResourceCommand, org.ikasan.connector.listener.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	Description
FileDiscoveryCommand()	No args constructor as required by Hibernate
FileDiscoveryCommand(java.lang.String sourceDirectory, java.lang.String filenamePattern, BaseFileTransferDao persistence, long minAge, boolean filterDuplicates, boolean filterOnFilename, boolean filterOnLastModifiedDate, boolean isRecursive)	Constructor (required for backwards compatibility)
FileDiscoveryCommand(java.lang.String sourceDirectory, java.lang.String filenamePattern, BaseFileTransferDao persistence, long minAge, boolean filterDuplicates, boolean filterOnFilename, boolean filterOnLastModifiedDate, boolean isRecursive, boolean chronological, boolean onlyFirstFile, com.google.common.cache.Cache<java.lang.String,java.lang.Boolean> duplicateFilesCache)	Constructor

Method Summary

Modifier and Type	Method	Description
protected void	doCommit()
protected void	doRollback()
protected java.util.List<ClientListEntry>	listDirectory(java.lang.String directory, java.util.List<ClientListEntry> allFiles)
protected org.ikasan.connector.base.command.ExecutionOutput	performExecute()	execute method for subclasses to implement
java.lang.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(java.lang.String sourceDirectory,
                            java.lang.String filenamePattern,
                            BaseFileTransferDao persistence,
                            long minAge,
                            boolean filterDuplicates,
                            boolean filterOnFilename,
                            boolean filterOnLastModifiedDate,
                            boolean isRecursive)

Constructor (required for backwards compatibility)

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

FileDiscoveryCommand

public FileDiscoveryCommand(java.lang.String sourceDirectory,
                            java.lang.String filenamePattern,
                            BaseFileTransferDao persistence,
                            long minAge,
                            boolean filterDuplicates,
                            boolean filterOnFilename,
                            boolean filterOnLastModifiedDate,
                            boolean isRecursive,
                            boolean chronological,
                            boolean onlyFirstFile,
                            com.google.common.cache.Cache<java.lang.String,java.lang.Boolean> duplicateFilesCache)

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

isRecursive - recursive

chronological - sort chronologically

onlyFirstFile - return first available result only

Method Detail

doCommit

protected void doCommit()

Specified by:

doCommit in class org.ikasan.connector.base.command.AbstractTransactionalResourceCommand

performExecute

protected org.ikasan.connector.base.command.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 org.ikasan.connector.base.command.AbstractTransactionalResourceCommand

listDirectory

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

Throws:

javax.resource.ResourceException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

See Also:

Object.toString()