org.ikasan.connector.basefiletransfer.outbound.command

Class ChecksumDeliveredCommand

java.lang.Object

org.ikasan.connector.base.command.AbstractTransactionalResourceCommand

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

org.ikasan.connector.basefiletransfer.outbound.command.ChecksumDeliveredCommand

All Implemented Interfaces:

TransactionalResourceCommand, TransactionCommitFailureObserverable

public class ChecksumDeliveredCommand
extends AbstractBaseFileTransferTransactionalResourceCommand

Command for comparing the calculated checksum of a delivered file with that provided by the remote system, if any

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
ChecksumDeliveredCommand() Constructor TODO Check that we should actually be calling super as that reloads state to be initial and we might not want that on reload of command from DB

Method Summary

Methods

Modifier and Type	Method and Description
protected void	doCommit()
protected void	doRollback()
static String	getChecksum(byte[] input) Get the MD5 checksum given an ImputStream
protected ExecutionOutput	performExecute() execute method for subclasses to implement

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, toString, wait, wait, wait

Constructor Detail

ChecksumDeliveredCommand

public ChecksumDeliveredCommand()

Constructor TODO Check that we should actually be calling super as that reloads state to be initial and we might not want that on reload of command from DB

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

getChecksum

public static String getChecksum(byte[] input)

Get the MD5 checksum given an ImputStream

Parameters:

byte - array for which to calculate the checksum

Returns:

String representing the checksum