org.ikasan.connector.basefiletransfer.outbound.command

Class AbstractBaseFileTransferTransactionalResourceCommand

java.lang.Object

org.ikasan.connector.base.command.AbstractTransactionalResourceCommand

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

All Implemented Interfaces:

TransactionalResourceCommand, TransactionCommitFailureObserverable

Direct Known Subclasses:

ChecksumDeliveredCommand, ChecksumValidatorCommand, CleanupChunksCommand, DeliverBatchCommand, DeliverFileCommand, FileDiscoveryCommand, RenameFileCommand, RetrieveFileCommand

public abstract class AbstractBaseFileTransferTransactionalResourceCommand
extends AbstractTransactionalResourceCommand
implements TransactionCommitFailureObserverable

This is the base class for all FileTransfer oriented TranasactionalResourceCommands This exists simply to provide access to all common low level File Transfer operations

Author:

Ikasan Development Team

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	CURRENT_DIRECTORY current directory
protected static String	EOL EOL character
protected String	fileSeparator The file separator
protected List<TransactionCommitFailureListener>	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
AbstractBaseFileTransferTransactionalResourceCommand() Constructor

Method Summary

Methods

Modifier and Type	Method and Description
void	addListener(TransactionCommitFailureListener listener)
protected void	changeDirectory(String path) Execute a change directory on the server to directory passed in
protected void	deleteDir(String directoryPath, boolean recurse) Deletes a remote directory
protected void	deleteFile(String filename) Deletes a remote file
ExecutionOutput	doExecute(TransactionalResource resource) (non-Javadoc)
protected ClientListEntry	findFile(String filePath) Find a file in the current directory if it exists
protected FileTransferClient	getClient() Return the FileTransferClient
protected InputStream	getContentAsStream(ClientListEntry entry) Get the content from the file as an InputStream
protected BaseFileTransferMappedRecord	getFile(ClientListEntry entry) Get the Mapped record that is a representation of the file
protected BaseFileTransferMappedRecord	getFile(String filePath) Get the SFYPMapped record that is a representation of the file
protected List<ClientListEntry>	listDirectory(String directory) Return a list of ClientListEntry objects
protected void	logFileList(List<ClientListEntry> list, String listDescription) Method used to log a list of ClientListEntry entries.
protected void	notifyListeners(TransactionCommitException exception)
protected abstract ExecutionOutput	performExecute() execute method for subclasses to implement
protected String	printWorkingDirectoryName() Returns the working directory name
protected void	putFile(BaseFileTransferMappedRecord file) Put the file given
protected void	putWithOutputStream(String fileName, InputStream inputStream) Perform a PUT file operation suing an OutputStream
protected void	renameFile(String oldPath, String newPath) Rename the file from oldPath to newPath

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

commit, doCommit, doRollback, 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, toString, wait, wait, wait

Field Detail

EOL

protected static final String EOL

EOL character

CURRENT_DIRECTORY

protected static final String CURRENT_DIRECTORY

current directory

See Also:

Constant Field Values

fileSeparator

protected String fileSeparator

The file separator

listeners

protected List<TransactionCommitFailureListener> listeners

Constructor Detail

AbstractBaseFileTransferTransactionalResourceCommand

public AbstractBaseFileTransferTransactionalResourceCommand()

Constructor

Method Detail

doExecute

public ExecutionOutput doExecute(TransactionalResource resource)
                          throws javax.resource.ResourceException

(non-Javadoc)

Specified by:

doExecute in class AbstractTransactionalResourceCommand

Throws:

javax.resource.ResourceException

See Also:

AbstractTransactionalResourceCommand.doExecute(org.ikasan.connector.base.command.TransactionalResource)

performExecute

protected abstract ExecutionOutput performExecute()
                                           throws javax.resource.ResourceException

execute method for subclasses to implement

Returns:

ExecutionOutput

Throws:

javax.resource.ResourceException - -

printWorkingDirectoryName

protected String printWorkingDirectoryName()
                                    throws javax.resource.ResourceException

Returns the working directory name

Returns:

working directory name

Throws:

javax.resource.ResourceException - -

changeDirectory

protected void changeDirectory(String path)
                        throws javax.resource.ResourceException

Execute a change directory on the server to directory passed in

Parameters:

path - Path to change directory to

Throws:

javax.resource.ResourceException - -

listDirectory

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

Return a list of ClientListEntry objects

Parameters:

directory - The directory we are listing on

Returns:

A list of ClientListEntry

Throws:

javax.resource.ResourceException - -

logFileList

protected void logFileList(List<ClientListEntry> list,
               String listDescription)

Method used to log a list of ClientListEntry entries. The level of detail logged depends on the runtime logging level.

Parameters:

list - - files in directory

listDescription - -

getFile

protected BaseFileTransferMappedRecord getFile(ClientListEntry entry)
                                        throws javax.resource.ResourceException

Get the Mapped record that is a representation of the file

Parameters:

entry - A wrapper that holds the information we need to get the file

Returns:

The BaseFileTransferMappedRecord representing the file

Throws:

javax.resource.ResourceException - failure to perform get

getFile

protected BaseFileTransferMappedRecord getFile(String filePath)
                                        throws javax.resource.ResourceException

Get the SFYPMapped record that is a representation of the file

Parameters:

filePath - The path to the file

Returns:

The BaseFileTransferMappedRecord representing the file

Throws:

javax.resource.ResourceException - - failure to perform get

renameFile

protected void renameFile(String oldPath,
              String newPath)
                   throws javax.resource.ResourceException

Rename the file from oldPath to newPath

Parameters:

oldPath - Original Path

newPath - New Path

Throws:

javax.resource.ResourceException - when renaming a file fails

putFile

protected void putFile(BaseFileTransferMappedRecord file)
                throws javax.resource.ResourceException

Put the file given

Parameters:

file - - the file

Throws:

javax.resource.ResourceException - when sending a file

deleteFile

protected void deleteFile(String filename)
                   throws javax.resource.ResourceException

Deletes a remote file

Parameters:

filename - - for file to be deleted

Throws:

javax.resource.ResourceException - when removing a file fails

deleteDir

protected void deleteDir(String directoryPath,
             boolean recurse)
                  throws javax.resource.ResourceException

Deletes a remote directory

Parameters:

directoryPath - - directory to be removed

recurse - - flag to delete directory recursively or not.

Throws:

javax.resource.ResourceException - when deleting a file fails

getContentAsStream

protected InputStream getContentAsStream(ClientListEntry entry)
                                  throws javax.resource.ResourceException

Get the content from the file as an InputStream

Parameters:

entry - - the file

Returns:

content as an InputStream

Throws:

javax.resource.ResourceException - when downloding a file gails

putWithOutputStream

protected void putWithOutputStream(String fileName,
                       InputStream inputStream)
                            throws javax.resource.ResourceException

Perform a PUT file operation suing an OutputStream

Parameters:

fileName - - the file name

inputStream - - file content as an input stream

Throws:

javax.resource.ResourceException - when sending a file fails

findFile

protected ClientListEntry findFile(String filePath)
                            throws javax.resource.ResourceException

Find a file in the current directory if it exists

Parameters:

filePath - - where to look for file

Returns:

file represented as a ClientListEntry

Throws:

javax.resource.ResourceException - when finding the file fails

getClient

protected FileTransferClient getClient()

Return the FileTransferClient

Returns:

FileTransferClient

addListener

public void addListener(TransactionCommitFailureListener listener)

Specified by:

addListener in interface TransactionCommitFailureObserverable

notifyListeners

protected void notifyListeners(TransactionCommitException exception)