com.modus.mule.modules.ftps.config

Class AbstractConfig

java.lang.Object

com.modus.mule.modules.ftps.config.AbstractConfig

Direct Known Subclasses:

BasicConfig, PartnerManagerConfig

public abstract class AbstractConfig
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected String	filePath
protected org.mule.api.MuleContext	muleContext

Constructor Summary

Constructors

Constructor and Description
AbstractConfig()

Method Summary

Modifier and Type	Method and Description
protected String	clean(Serializable obj)
org.mule.api.MuleEvent	createMuleEvent(Object payload, org.mule.api.callback.SourceCallback callback)
abstract FTPSClientConfig	getDefaultConnectionSetup(com.mulesoft.api.b2b.Direction direction)
String	getFilename()
String	getFilePath()
abstract org.apache.commons.net.ftp.FTPSClient	getInboundConnection(FTPSClientConfig key)
org.mule.util.lock.LockFactory	getLockFactory()
Integer	getMaxConcurrentReads()
String	getMoveToDir()
String	getMoveToFilename()
org.mule.api.MuleContext	getMuleContext()
abstract org.apache.commons.net.ftp.FTPSClient	getOutboundConnection(FTPSClientConfig key)
long	getPollingFrequency()
long	getPollingInitialDelay()
org.apache.commons.pool2.impl.GenericKeyedObjectPool<FTPSClientConfig,org.apache.commons.net.ftp.FTPSClient>	getPool()
long	getSizeCheckWaitTime()
abstract Boolean	getStreaming()
String	getUploadTmpDir()
Integer	getZeroSizeCheckMaxRetries()
long	getZeroSizeCheckWaitTime()
boolean	getZeroSizedIgnored()
void	initializeInboundParameters(String filePath, String fileName, String moveToDir, String moveToFilename, long pollingFrequency, long sizeCheckWaitTime, boolean zeroSizedIgnored, long zeroSizeCheckWaitTime, Integer zeroSizeCheckMaxRetries)
void	initializeOutboundParameters(String filePath, String fileName)
abstract Boolean	isPartnerManager()
boolean	isStreaming()
void	overrideOutboundOperationSettings(String oUploadTmpDir, Boolean oStreaming)
String	parseMEL(String melExpression, org.mule.api.MuleEvent muleEvent)
String	parseMEL(String melExpression, org.mule.api.callback.SourceCallback callback)
protected void	preparePool(FTPSClientConfig key)
abstract Object	recordTransmissionResults(FTPResult.FTPResultStatus status, com.mulesoft.api.b2b.Direction direction, org.apache.commons.net.ftp.FTPSClient client, String filename, String errorMessage, org.mule.api.MuleEvent event)
void	returnConnection(FTPSClientConfig key, org.apache.commons.net.ftp.FTPSClient ftps)
void	setFilename(String filename)
void	setFilePath(String filePath)
void	setLockFactory(org.mule.util.lock.LockFactory lockFactory)
void	setMaxConcurrentReads(Integer maxConcurrentReads)
void	setMoveToDir(String moveToDir)
void	setMoveToFilename(String moveToFilename)
void	setMuleContext(org.mule.api.MuleContext muleContext)
void	setPollingFrequency(long pollingFrequency)
void	setPollingInitialDelay(long pollingInitialDelay)
void	setSizeCheckWaitTime(long sizeCheckWaitTime)
void	setStreaming(boolean streaming)
void	setUploadTmpDir(String uploadTmpDir)
void	setZeroSizeCheckMaxRetries(Integer zeroSizeCheckMaxRetries)
void	setZeroSizeCheckWaitTime(long zeroSizeCheckWaitTime)
void	setZeroSizedIgnored(boolean zeroSizedIgnored)
void	validateIncompatibleOutboundConfig(Boolean appendContents)

Methods inherited from class java.lang.Object

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

Field Detail

muleContext

@Inject
protected org.mule.api.MuleContext muleContext

filePath

protected String filePath

Constructor Detail

AbstractConfig

public AbstractConfig()

Method Detail

getFilename

public String getFilename()

getUploadTmpDir

public String getUploadTmpDir()

getFilePath

public String getFilePath()

getMoveToDir

public String getMoveToDir()

getMoveToFilename

public String getMoveToFilename()

getMaxConcurrentReads

public Integer getMaxConcurrentReads()

isStreaming

public boolean isStreaming()

getSizeCheckWaitTime

public long getSizeCheckWaitTime()

setSizeCheckWaitTime

public void setSizeCheckWaitTime(long sizeCheckWaitTime)

setMuleContext

public void setMuleContext(org.mule.api.MuleContext muleContext)

getMuleContext

public org.mule.api.MuleContext getMuleContext()

getPollingFrequency

public long getPollingFrequency()

setPollingFrequency

public void setPollingFrequency(long pollingFrequency)

setFilePath

public void setFilePath(String filePath)

setMoveToDir

public void setMoveToDir(String moveToDir)

setMoveToFilename

public void setMoveToFilename(String moveToFilename)

setMaxConcurrentReads

public void setMaxConcurrentReads(Integer maxConcurrentReads)

setStreaming

public void setStreaming(boolean streaming)

getInboundConnection

public abstract org.apache.commons.net.ftp.FTPSClient getInboundConnection(FTPSClientConfig key)
                                                                    throws Exception

Throws:

Exception

getOutboundConnection

public abstract org.apache.commons.net.ftp.FTPSClient getOutboundConnection(FTPSClientConfig key)
                                                                     throws Exception

Throws:

Exception

setUploadTmpDir

public void setUploadTmpDir(String uploadTmpDir)

setFilename

public void setFilename(String filename)

getPollingInitialDelay

public long getPollingInitialDelay()

setPollingInitialDelay

public void setPollingInitialDelay(long pollingInitialDelay)

getLockFactory

public org.mule.util.lock.LockFactory getLockFactory()

setLockFactory

public void setLockFactory(org.mule.util.lock.LockFactory lockFactory)

getZeroSizedIgnored

public boolean getZeroSizedIgnored()

setZeroSizedIgnored

public void setZeroSizedIgnored(boolean zeroSizedIgnored)

getZeroSizeCheckWaitTime

public long getZeroSizeCheckWaitTime()

setZeroSizeCheckWaitTime

public void setZeroSizeCheckWaitTime(long zeroSizeCheckWaitTime)

getZeroSizeCheckMaxRetries

public Integer getZeroSizeCheckMaxRetries()

setZeroSizeCheckMaxRetries

public void setZeroSizeCheckMaxRetries(Integer zeroSizeCheckMaxRetries)

recordTransmissionResults

public abstract Object recordTransmissionResults(FTPResult.FTPResultStatus status,
                                                 com.mulesoft.api.b2b.Direction direction,
                                                 org.apache.commons.net.ftp.FTPSClient client,
                                                 String filename,
                                                 String errorMessage,
                                                 org.mule.api.MuleEvent event)

getDefaultConnectionSetup

public abstract FTPSClientConfig getDefaultConnectionSetup(com.mulesoft.api.b2b.Direction direction)
                                                    throws Exception

Throws:

Exception

createMuleEvent

public org.mule.api.MuleEvent createMuleEvent(Object payload,
                                              org.mule.api.callback.SourceCallback callback)

parseMEL

public String parseMEL(String melExpression,
                       org.mule.api.callback.SourceCallback callback)

parseMEL

public String parseMEL(String melExpression,
                       org.mule.api.MuleEvent muleEvent)

isPartnerManager

public abstract Boolean isPartnerManager()

getStreaming

public abstract Boolean getStreaming()

clean

protected String clean(Serializable obj)

getPool

public org.apache.commons.pool2.impl.GenericKeyedObjectPool<FTPSClientConfig,org.apache.commons.net.ftp.FTPSClient> getPool()

initializeInboundParameters

public void initializeInboundParameters(String filePath,
                                        String fileName,
                                        String moveToDir,
                                        String moveToFilename,
                                        long pollingFrequency,
                                        long sizeCheckWaitTime,
                                        boolean zeroSizedIgnored,
                                        long zeroSizeCheckWaitTime,
                                        Integer zeroSizeCheckMaxRetries)

initializeOutboundParameters

public void initializeOutboundParameters(String filePath,
                                         String fileName)

overrideOutboundOperationSettings

public void overrideOutboundOperationSettings(String oUploadTmpDir,
                                              Boolean oStreaming)

validateIncompatibleOutboundConfig

public void validateIncompatibleOutboundConfig(Boolean appendContents)
                                        throws FTPSConnectorException

Throws:

FTPSConnectorException

returnConnection

public void returnConnection(FTPSClientConfig key,
                             org.apache.commons.net.ftp.FTPSClient ftps)
                      throws Exception

Throws:

Exception

preparePool

protected void preparePool(FTPSClientConfig key)
                    throws Exception

Throws:

Exception