org.ikasan.connector.basefiletransfer.outbound.command

Class RetrieveFileCommand

java.lang.Object

org.ikasan.connector.base.command.AbstractTransactionalResourceCommand

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

org.ikasan.connector.basefiletransfer.outbound.command.RetrieveFileCommand

All Implemented Interfaces:

TransactionalResourceCommand, TransactionCommitFailureObserverable

Direct Known Subclasses:

ChunkingRetrieveFileCommand

public class RetrieveFileCommand
extends AbstractBaseFileTransferTransactionalResourceCommand

Retrieves a specified file from a remote directory

Author:

Ikasan Development Team

Field Summary

Fields

Modifier and Type	Field and Description
protected BaseFileTransferDao	dao Data Access Object for Base File Transfer
protected boolean	destructive Whether or not to destroy the file after we pick it up
protected String	renameExtension Extension with which to rename successfully retrieved files As optional timestamp can be specified by using a pattern of /[dateFormat]/ in the renameExtension e.g.
protected boolean	renameOnSuccess Rename the file on successful retrieval
protected Pattern	renameTimestampExtensionPattern Pattern used in replacing a timestamp in a rename extension, for instance, captures /[dateFormat]/
protected String	sourcePath The original source path of the file we are retrieving

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

Modifier	Constructor and Description
protected	RetrieveFileCommand() No args constructor required by Hibernate and unit tests
	RetrieveFileCommand(BaseFileTransferDao dao, boolean renameOnSuccess, String renameExtension, boolean moveOnSuccess, String moveOnSuccessNewPath, boolean destructive) Constructor

Method Summary

Methods

Modifier and Type	Method and Description
protected void	doCommit() (non-Javadoc)
protected void	doRollback() (non-Javadoc)
protected String	expandRenameExtension()
String	getMoveNewPath() Get the new path a file is being moved to.
String	getRenameExtension() Get the extension that we'rerenaming the file with
String	getSourcePath() Accessor method for source path
boolean	isDestructive() Do we delete the file on successful delivery?
boolean	isMoveOnSuccess() Do we move the file on successful delivery?
boolean	isRenameOnSuccess() Do we rename the file on successful delivery?
protected void	parseTimestampFormat()
protected ExecutionOutput	performExecute() (non-Javadoc)
protected void	setRenameExtension(String renameExtension) Private setter used by Hibernate
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

Field Detail

dao

protected BaseFileTransferDao dao

Data Access Object for Base File Transfer

sourcePath

protected String sourcePath

The original source path of the file we are retrieving

renameOnSuccess

protected boolean renameOnSuccess

Rename the file on successful retrieval

renameExtension

protected String renameExtension

Extension with which to rename successfully retrieved files As optional timestamp can be specified by using a pattern of /[dateFormat]/ in the renameExtension e.g. "/yyyyMMddHHmmss/.complete"

destructive

protected boolean destructive

Whether or not to destroy the file after we pick it up

renameTimestampExtensionPattern

protected Pattern renameTimestampExtensionPattern

Pattern used in replacing a timestamp in a rename extension, for instance, captures /[dateFormat]/

Constructor Detail

RetrieveFileCommand

protected RetrieveFileCommand()

No args constructor required by Hibernate and unit tests

RetrieveFileCommand

public RetrieveFileCommand(BaseFileTransferDao dao,
                   boolean renameOnSuccess,
                   String renameExtension,
                   boolean moveOnSuccess,
                   String moveOnSuccessNewPath,
                   boolean destructive)

Constructor

Parameters:

dao - hibernateDAO

renameOnSuccess - flag

renameExtension - to rename file

moveOnSuccess - flag

moveOnSuccessNewPath - to move file

destructive - flag

Method Detail

performExecute

protected ExecutionOutput performExecute()
                                  throws javax.resource.ResourceException

(non-Javadoc)

Specified by:

performExecute in class AbstractBaseFileTransferTransactionalResourceCommand

Returns:

ExecutionOutput

Throws:

javax.resource.ResourceException - -

See Also:

AbstractBaseFileTransferTransactionalResourceCommand.performExecute()

doCommit

protected void doCommit()
                 throws javax.resource.ResourceException

(non-Javadoc)

Specified by:

doCommit in class AbstractTransactionalResourceCommand

Throws:

javax.resource.ResourceException

See Also:

AbstractTransactionalResourceCommand.doCommit()

doRollback

protected void doRollback()

(non-Javadoc)

Specified by:

doRollback in class AbstractTransactionalResourceCommand

See Also:

AbstractTransactionalResourceCommand.doRollback()

expandRenameExtension

protected String expandRenameExtension()

parseTimestampFormat

protected void parseTimestampFormat()

toString

public String toString()

Overrides:

toString in class Object

See Also:

Object.toString()

getSourcePath

public String getSourcePath()

Accessor method for source path

Returns:

sourcePath

isRenameOnSuccess

public boolean isRenameOnSuccess()

Do we rename the file on successful delivery?

Returns:

true if we rename, else false

getRenameExtension

public String getRenameExtension()

Get the extension that we'rerenaming the file with

Returns:

file extension for the renamed file

setRenameExtension

protected void setRenameExtension(String renameExtension)

Private setter used by Hibernate

Parameters:

renameExtension - when renaming file

isDestructive

public boolean isDestructive()

Do we delete the file on successful delivery?

Returns:

true if we delete, else false

isMoveOnSuccess

public boolean isMoveOnSuccess()

Do we move the file on successful delivery?

Returns:

moveOnSuccess

getMoveNewPath

public String getMoveNewPath()

Get the new path a file is being moved to.

Returns:

moveNewPath