org.ikasan.connector.basefiletransfer.outbound.command

Class ChunkingRetrieveFileCommand

java.lang.Object

org.ikasan.connector.base.command.AbstractTransactionalResourceCommand

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

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

org.ikasan.connector.basefiletransfer.outbound.command.ChunkingRetrieveFileCommand

All Implemented Interfaces:

TransactionalResourceCommand, TransactionCommitFailureObserverable, ChunkableDataProvider

public class ChunkingRetrieveFileCommand
extends RetrieveFileCommand
implements ChunkableDataProvider

Retrieves a specified file from a remote directory

Author:

Ikasan Development Team

Field Summary

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

dao, destructive, renameExtension, renameOnSuccess, renameTimestampExtensionPattern, sourcePath

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
ChunkingRetrieveFileCommand(BaseFileTransferDao dao, String clientId, boolean renameOnSuccess, String renameExtension, boolean moveOnSuccess, String moveNewPath, FileChunkDao fileChunkDao, int chunkSize, boolean destructive) Constructor

Method Summary

Methods

Modifier and Type	Method and Description
void	connect()
void	disconnect()
long	getFileSize(String remoteDir, String fileName)
String	getSourcePath() Accessor method for source path
protected ExecutionOutput	performExecute() (non-Javadoc)
InputStream	sourceChunkableData(String remoteDir, String fileName)
void	sourceChunkableData(String remoteDir, String fileName, OutputStream outputStream, long offset)
String	toString()

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

doCommit, doRollback, expandRenameExtension, getMoveNewPath, getRenameExtension, isDestructive, isMoveOnSuccess, isRenameOnSuccess, parseTimestampFormat, setRenameExtension

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

ChunkingRetrieveFileCommand

public ChunkingRetrieveFileCommand(BaseFileTransferDao dao,
                           String clientId,
                           boolean renameOnSuccess,
                           String renameExtension,
                           boolean moveOnSuccess,
                           String moveNewPath,
                           FileChunkDao fileChunkDao,
                           int chunkSize,
                           boolean destructive)

Constructor

Parameters:

dao -

clientId -

renameOnSuccess -

renameExtension -

moveOnSuccess -

moveNewPath -

fileChunkDao -

chunkSize -

destructive -

Method Detail

performExecute

protected ExecutionOutput performExecute()
                                  throws javax.resource.ResourceException

Description copied from class: RetrieveFileCommand

(non-Javadoc)

Overrides:

performExecute in class RetrieveFileCommand

Returns:

ExecutionOutput

Throws:

javax.resource.ResourceException - -

See Also:

AbstractBaseFileTransferTransactionalResourceCommand.performExecute()

toString

public String toString()

Overrides:

toString in class RetrieveFileCommand

See Also:

Object.toString()

getSourcePath

public String getSourcePath()

Accessor method for source path

Overrides:

getSourcePath in class RetrieveFileCommand

Returns:

sourcePath

connect

public void connect()

Specified by:

connect in interface ChunkableDataProvider

disconnect

public void disconnect()

Specified by:

disconnect in interface ChunkableDataProvider

getFileSize

public long getFileSize(String remoteDir,
               String fileName)
                 throws ChunkableDataSourceException

Specified by:

getFileSize in interface ChunkableDataProvider

Throws:

ChunkableDataSourceException

sourceChunkableData

public InputStream sourceChunkableData(String remoteDir,
                              String fileName)
                                throws ChunkableDataSourceException

Specified by:

sourceChunkableData in interface ChunkableDataProvider

Throws:

ChunkableDataSourceException

sourceChunkableData

public void sourceChunkableData(String remoteDir,
                       String fileName,
                       OutputStream outputStream,
                       long offset)
                         throws ChunkableDataSourceException

Specified by:

sourceChunkableData in interface ChunkableDataProvider

Throws:

ChunkableDataSourceException