org.ikasan.endpoint.ftp.producer

Class FtpProducer

java.lang.Object

org.ikasan.endpoint.ftp.producer.FtpProducer

All Implemented Interfaces:

TransactionCommitFailureListener, Producer<Payload>, Configured<FtpProducerConfiguration>, ConfiguredResource<FtpProducerConfiguration>, ManagedResource

public class FtpProducer
extends Object
implements Producer<Payload>, ManagedResource, ConfiguredResource<FtpProducerConfiguration>, TransactionCommitFailureListener

FTP Implementation of a producer based on the JCA specification.

Author:

Middleware Team

Field Summary

Fields

Modifier and Type	Field and Description
protected FileTransferConnectionTemplate	activeFileTransferConnectionTemplate Currently active connection template
protected FileTransferConnectionTemplate	alternateFileTransferConnectionTemplate Alternate template to be used in cases of failure
protected FtpProducerConfiguration	configuration Configuration - default to vanilla instance
protected String	configuredResourceId configured resource id
protected FileTransferConnectionTemplate	fileTransferConnectionTemplate A connection template
protected boolean	isCriticalOnStartup determines whether this managed resource failure will fail the startup of the flow

Constructor Summary

Constructors

Constructor and Description
FtpProducer(org.springframework.transaction.jta.JtaTransactionManager transactionManager, BaseFileTransferDao baseFileTransferDao, FileChunkDao fileChunkDao, TransactionalResourceCommandDAO transactionalResourceCommandDAO)

Method Summary

Modifier and Type	Method and Description
void	commitFailureOccurred(TransactionCommitEvent event)
FtpProducerConfiguration	getConfiguration()
String	getConfiguredResourceId()
protected FTPConnectionSpec	getConnectionSpec() Utility method to aid testing of this class
void	invoke(Payload payload)
boolean	isCriticalOnStartup()
void	setConfiguration(FtpProducerConfiguration configuration)
void	setConfiguredResourceId(String configuredResourceId)
void	setCriticalOnStartup(boolean isCriticalOnStartup)
void	setManagedResourceRecoveryManager(ManagedResourceRecoveryManager managedResourceRecoveryManager)
void	startManagedResource()
void	stopManagedResource()
protected void	switchActiveConnection() Switch the active connection to the other connection template.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

configuredResourceId

protected String configuredResourceId

configured resource id

configuration

protected FtpProducerConfiguration configuration

Configuration - default to vanilla instance

activeFileTransferConnectionTemplate

protected FileTransferConnectionTemplate activeFileTransferConnectionTemplate

Currently active connection template

fileTransferConnectionTemplate

protected FileTransferConnectionTemplate fileTransferConnectionTemplate

A connection template

alternateFileTransferConnectionTemplate

protected FileTransferConnectionTemplate alternateFileTransferConnectionTemplate

Alternate template to be used in cases of failure

isCriticalOnStartup

protected boolean isCriticalOnStartup

determines whether this managed resource failure will fail the startup of the flow

Constructor Detail

FtpProducer

public FtpProducer(org.springframework.transaction.jta.JtaTransactionManager transactionManager,
                   BaseFileTransferDao baseFileTransferDao,
                   FileChunkDao fileChunkDao,
                   TransactionalResourceCommandDAO transactionalResourceCommandDAO)

Method Detail

getConfiguration

public FtpProducerConfiguration getConfiguration()

Specified by:

getConfiguration in interface Configured<FtpProducerConfiguration>

getConfiguredResourceId

public String getConfiguredResourceId()

Specified by:

getConfiguredResourceId in interface ConfiguredResource<FtpProducerConfiguration>

setConfiguration

public void setConfiguration(FtpProducerConfiguration configuration)

Specified by:

setConfiguration in interface Configured<FtpProducerConfiguration>

setConfiguredResourceId

public void setConfiguredResourceId(String configuredResourceId)

Specified by:

setConfiguredResourceId in interface ConfiguredResource<FtpProducerConfiguration>

invoke

public void invoke(Payload payload)
            throws EndpointException

Specified by:

invoke in interface Producer<Payload>

Throws:

EndpointException

switchActiveConnection

protected void switchActiveConnection()

Switch the active connection to the other connection template.

startManagedResource

public void startManagedResource()

Specified by:

startManagedResource in interface ManagedResource

stopManagedResource

public void stopManagedResource()

Specified by:

stopManagedResource in interface ManagedResource

isCriticalOnStartup

public boolean isCriticalOnStartup()

Specified by:

isCriticalOnStartup in interface ManagedResource

setCriticalOnStartup

public void setCriticalOnStartup(boolean isCriticalOnStartup)

Specified by:

setCriticalOnStartup in interface ManagedResource

setManagedResourceRecoveryManager

public void setManagedResourceRecoveryManager(ManagedResourceRecoveryManager managedResourceRecoveryManager)

Specified by:

setManagedResourceRecoveryManager in interface ManagedResource

getConnectionSpec

protected FTPConnectionSpec getConnectionSpec()

Utility method to aid testing of this class

Returns:

commitFailureOccurred

public void commitFailureOccurred(TransactionCommitEvent event)

Specified by:

commitFailureOccurred in interface TransactionCommitFailureListener