org.springframework.integration.ftp.gateway

Class FtpOutboundGateway

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.handler.AbstractMessageHandler

org.springframework.integration.handler.AbstractMessageProducingHandler

org.springframework.integration.handler.AbstractReplyProducingMessageHandler

org.springframework.integration.file.remote.gateway.AbstractRemoteFileOutboundGateway<org.apache.commons.net.ftp.FTPFile>

org.springframework.integration.ftp.gateway.FtpOutboundGateway

All Implemented Interfaces:

org.reactivestreams.Subscriber<org.springframework.messaging.Message<?>>, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanClassLoaderAware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.core.Ordered, ExpressionCapable, Orderable, MessageProducer, HeaderPropagationAware, NamedComponent, ConfigurableMetricsAware<AbstractMessageHandlerMetrics>, IntegrationManagement, IntegrationStatsManagement, MessageHandlerMetrics, TrackableComponent, org.springframework.messaging.MessageHandler, reactor.core.CoreSubscriber<org.springframework.messaging.Message<?>>

public class FtpOutboundGateway
extends AbstractRemoteFileOutboundGateway<org.apache.commons.net.ftp.FTPFile>

Outbound Gateway for performing remote file operations via FTP/FTPS.

Since:

2.1

Author:

Gary Russell, Artem Bilan

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.integration.file.remote.gateway.AbstractRemoteFileOutboundGateway

AbstractRemoteFileOutboundGateway.Command, AbstractRemoteFileOutboundGateway.Option

Nested classes/interfaces inherited from class org.springframework.integration.handler.AbstractReplyProducingMessageHandler

AbstractReplyProducingMessageHandler.RequestHandler

Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement

IntegrationManagement.ManagementOverrides

Field Summary

Fields inherited from class org.springframework.integration.file.remote.gateway.AbstractRemoteFileOutboundGateway

command, options, remoteFileTemplate

Fields inherited from class org.springframework.integration.handler.AbstractMessageProducingHandler

messagingTemplate

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

EXPRESSION_PARSER, logger

Fields inherited from interface org.springframework.integration.support.management.IntegrationManagement

METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor and Description
FtpOutboundGateway(RemoteFileTemplate<org.apache.commons.net.ftp.FTPFile> remoteFileTemplate, MessageSessionCallback<org.apache.commons.net.ftp.FTPFile,?> messageSessionCallback) Construct an instance with the supplied remote file template and callback for performing operations on the session.
FtpOutboundGateway(RemoteFileTemplate<org.apache.commons.net.ftp.FTPFile> remoteFileTemplate, java.lang.String command) Construct an instance with the supplied remote file template and command ('ls', 'nlst', 'put' or 'mput').
FtpOutboundGateway(RemoteFileTemplate<org.apache.commons.net.ftp.FTPFile> remoteFileTemplate, java.lang.String command, java.lang.String expression) Construct an instance with the supplied remote file template, a command ('ls', 'get' etc), and an expression to determine the filename.
FtpOutboundGateway(SessionFactory<org.apache.commons.net.ftp.FTPFile> sessionFactory, MessageSessionCallback<org.apache.commons.net.ftp.FTPFile,?> messageSessionCallback) Construct an instance using the provided session factory and callback for performing operations on the session.
FtpOutboundGateway(SessionFactory<org.apache.commons.net.ftp.FTPFile> sessionFactory, java.lang.String command) Construct an instance with the supplied session factory and command ('ls', 'nlst', 'put' or 'mput').
FtpOutboundGateway(SessionFactory<org.apache.commons.net.ftp.FTPFile> sessionFactory, java.lang.String command, java.lang.String expression) Construct an instance with the supplied session factory, a command ('ls', 'get' etc), and an expression to determine the filename.

Method Summary

Modifier and Type	Method and Description
protected java.util.List<AbstractFileInfo<org.apache.commons.net.ftp.FTPFile>>	asFileInfoList(java.util.Collection<org.apache.commons.net.ftp.FTPFile> files)
protected void	doInit()
protected org.apache.commons.net.ftp.FTPFile	enhanceNameWithSubDirectory(org.apache.commons.net.ftp.FTPFile file, java.lang.String directory)
protected java.io.File	get(org.springframework.messaging.Message<?> message, Session<org.apache.commons.net.ftp.FTPFile> session, java.lang.String remoteDir, java.lang.String remoteFilePath, java.lang.String remoteFilename, org.apache.commons.net.ftp.FTPFile fileInfoParam) Copy a remote file to the configured local directory.
java.lang.String	getComponentType() Subclasses may implement this method to provide component type information.
protected java.lang.String	getFilename(AbstractFileInfo<org.apache.commons.net.ftp.FTPFile> file)
protected java.lang.String	getFilename(org.apache.commons.net.ftp.FTPFile file)
protected long	getModified(org.apache.commons.net.ftp.FTPFile file)
protected boolean	isDirectory(org.apache.commons.net.ftp.FTPFile file)
protected boolean	isLink(org.apache.commons.net.ftp.FTPFile file)
protected java.util.List<?>	ls(org.springframework.messaging.Message<?> message, Session<org.apache.commons.net.ftp.FTPFile> session, java.lang.String dir) List remote files to local representation.
protected java.util.List<java.io.File>	mGet(org.springframework.messaging.Message<?> message, Session<org.apache.commons.net.ftp.FTPFile> session, java.lang.String remoteDirectory, java.lang.String remoteFilename)
protected java.util.List<java.lang.String>	mPut(org.springframework.messaging.Message<?> message, Session<org.apache.commons.net.ftp.FTPFile> session, java.io.File localDir) Put files from the provided directory to the remote server recursively.
protected boolean	mv(org.springframework.messaging.Message<?> message, Session<org.apache.commons.net.ftp.FTPFile> session, java.lang.String remoteFilePath, java.lang.String remoteFileNewPath) Move one remote path to another.
protected java.util.List<java.lang.String>	nlst(org.springframework.messaging.Message<?> message, Session<org.apache.commons.net.ftp.FTPFile> session, java.lang.String dir) List remote files names for the provided directory.
protected java.lang.String	put(org.springframework.messaging.Message<?> message, Session<org.apache.commons.net.ftp.FTPFile> session, java.lang.String subDirectory) Put the file based on the message to the remote server.
protected boolean	rm(org.springframework.messaging.Message<?> message, Session<org.apache.commons.net.ftp.FTPFile> session, java.lang.String remoteFilePath) Perform remote delete for the provided path.
void	setWorkingDirExpression(org.springframework.expression.Expression workingDirExpression) Specify an Expression to evaluate FTP client working directory against request message.
void	setWorkingDirExpressionString(java.lang.String workingDirExpression) Specify a SpEL Expression to evaluate FTP client working directory against request message.

Methods inherited from class org.springframework.integration.file.remote.gateway.AbstractRemoteFileOutboundGateway

doChmod, filterFiles, filterMputFiles, getRemoteFilename, handleRequestMessage, isChmodCapable, purgeDots, purgeLinks, setAutoCreateLocalDirectory, setChmod, setChmodOctal, setFileExistsMode, setFilter, setLocalDirectory, setLocalDirectoryExpression, setLocalDirectoryExpressionString, setLocalFilenameGeneratorExpression, setLocalFilenameGeneratorExpressionString, setMputFilter, setOption, setOptions, setRemoteFileSeparator, setRenameExpression, setRenameExpressionString, setTemporaryFileSuffix

Methods inherited from class org.springframework.integration.handler.AbstractReplyProducingMessageHandler

doInvokeAdvisedRequestHandler, getRequiresReply, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader, setRequiresReply

Methods inherited from class org.springframework.integration.handler.AbstractMessageProducingHandler

addNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, setSendTimeout, shouldCopyRequestHeaders, shouldSplitOutput, updateNotPropagatedHeaders

Methods inherited from class org.springframework.integration.handler.AbstractMessageHandler

configureMetrics, getActiveCount, getActiveCountLong, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getOverrides, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onComplete, onError, onNext, onSubscribe, registerMetricsCaptor, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabled

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.integration.support.context.NamedComponent

getComponentName

Methods inherited from interface reactor.core.CoreSubscriber

currentContext

Constructor Detail

FtpOutboundGateway

public FtpOutboundGateway(SessionFactory<org.apache.commons.net.ftp.FTPFile> sessionFactory,
                          MessageSessionCallback<org.apache.commons.net.ftp.FTPFile,?> messageSessionCallback)

Construct an instance using the provided session factory and callback for performing operations on the session.

Parameters:

sessionFactory - the session factory.

messageSessionCallback - the callback.

FtpOutboundGateway

public FtpOutboundGateway(RemoteFileTemplate<org.apache.commons.net.ftp.FTPFile> remoteFileTemplate,
                          MessageSessionCallback<org.apache.commons.net.ftp.FTPFile,?> messageSessionCallback)

Construct an instance with the supplied remote file template and callback for performing operations on the session.

Parameters:

remoteFileTemplate - the remote file template.

messageSessionCallback - the callback.

FtpOutboundGateway

public FtpOutboundGateway(SessionFactory<org.apache.commons.net.ftp.FTPFile> sessionFactory,
                          java.lang.String command,
                          java.lang.String expression)

Construct an instance with the supplied session factory, a command ('ls', 'get' etc), and an expression to determine the filename.

Parameters:

sessionFactory - the session factory.

command - the command.

expression - the filename expression.

FtpOutboundGateway

public FtpOutboundGateway(RemoteFileTemplate<org.apache.commons.net.ftp.FTPFile> remoteFileTemplate,
                          java.lang.String command,
                          java.lang.String expression)

Construct an instance with the supplied remote file template, a command ('ls', 'get' etc), and an expression to determine the filename.

Parameters:

remoteFileTemplate - the remote file template.

command - the command.

expression - the filename expression.

FtpOutboundGateway

public FtpOutboundGateway(SessionFactory<org.apache.commons.net.ftp.FTPFile> sessionFactory,
                          java.lang.String command)

Construct an instance with the supplied session factory and command ('ls', 'nlst', 'put' or 'mput').

The remoteDirectory expression is null assuming to use the workingDirectory from the FTP Client.

Parameters:

sessionFactory - the session factory.

command - the command.

Since:

4.3

FtpOutboundGateway

public FtpOutboundGateway(RemoteFileTemplate<org.apache.commons.net.ftp.FTPFile> remoteFileTemplate,
                          java.lang.String command)

Construct an instance with the supplied remote file template and command ('ls', 'nlst', 'put' or 'mput').

The remoteDirectory expression is null assuming to use the workingDirectory from the FTP Client.

Parameters:

remoteFileTemplate - the remote file template.

command - the command.

Since:

4.3

Method Detail

setWorkingDirExpression

public void setWorkingDirExpression(org.springframework.expression.Expression workingDirExpression)

Specify an Expression to evaluate FTP client working directory against request message.

Parameters:

workingDirExpression - the expression to evaluate working directory

Since:

5.0

setWorkingDirExpressionString

public void setWorkingDirExpressionString(java.lang.String workingDirExpression)

Specify a SpEL Expression to evaluate FTP client working directory against request message.

Parameters:

workingDirExpression - the SpEL expression to evaluate working directory

Since:

5.0

getComponentType

public java.lang.String getComponentType()

Description copied from class: IntegrationObjectSupport

Subclasses may implement this method to provide component type information.

Specified by:

getComponentType in interface NamedComponent

Overrides:

getComponentType in class AbstractMessageHandler

isDirectory

protected boolean isDirectory(org.apache.commons.net.ftp.FTPFile file)

Specified by:

isDirectory in class AbstractRemoteFileOutboundGateway<org.apache.commons.net.ftp.FTPFile>

isLink

protected boolean isLink(org.apache.commons.net.ftp.FTPFile file)

Specified by:

isLink in class AbstractRemoteFileOutboundGateway<org.apache.commons.net.ftp.FTPFile>

getFilename

protected java.lang.String getFilename(org.apache.commons.net.ftp.FTPFile file)

Specified by:

getFilename in class AbstractRemoteFileOutboundGateway<org.apache.commons.net.ftp.FTPFile>

getFilename

protected java.lang.String getFilename(AbstractFileInfo<org.apache.commons.net.ftp.FTPFile> file)

Specified by:

getFilename in class AbstractRemoteFileOutboundGateway<org.apache.commons.net.ftp.FTPFile>

getModified

protected long getModified(org.apache.commons.net.ftp.FTPFile file)

Specified by:

getModified in class AbstractRemoteFileOutboundGateway<org.apache.commons.net.ftp.FTPFile>

asFileInfoList

protected java.util.List<AbstractFileInfo<org.apache.commons.net.ftp.FTPFile>> asFileInfoList(java.util.Collection<org.apache.commons.net.ftp.FTPFile> files)

Specified by:

asFileInfoList in class AbstractRemoteFileOutboundGateway<org.apache.commons.net.ftp.FTPFile>

doInit

protected void doInit()

Overrides:

doInit in class AbstractRemoteFileOutboundGateway<org.apache.commons.net.ftp.FTPFile>

enhanceNameWithSubDirectory

protected org.apache.commons.net.ftp.FTPFile enhanceNameWithSubDirectory(org.apache.commons.net.ftp.FTPFile file,
                                                                         java.lang.String directory)

Specified by:

enhanceNameWithSubDirectory in class AbstractRemoteFileOutboundGateway<org.apache.commons.net.ftp.FTPFile>

ls

protected java.util.List<?> ls(org.springframework.messaging.Message<?> message,
                               Session<org.apache.commons.net.ftp.FTPFile> session,
                               java.lang.String dir)
                        throws java.io.IOException

Description copied from class: AbstractRemoteFileOutboundGateway

List remote files to local representation. The message can be consulted for some context for the current request; isn't used in the default implementation.

Overrides:

ls in class AbstractRemoteFileOutboundGateway<org.apache.commons.net.ftp.FTPFile>

Parameters:

message - the message related to the list request

session - the session to perform list command

dir - the remote directory to list content

Returns:

the list of remote files

Throws:

java.io.IOException - the IO exception during performing remote command

nlst

protected java.util.List<java.lang.String> nlst(org.springframework.messaging.Message<?> message,
                                                Session<org.apache.commons.net.ftp.FTPFile> session,
                                                java.lang.String dir)
                                         throws java.io.IOException

Description copied from class: AbstractRemoteFileOutboundGateway

List remote files names for the provided directory. The message can be consulted for some context related to the current request; isn't used in the default implementation.

Overrides:

nlst in class AbstractRemoteFileOutboundGateway<org.apache.commons.net.ftp.FTPFile>

Parameters:

message - the message related to the current request

session - the session to perform list file names command

dir - the remote directory to list file names

Returns:

the list of file/directory names in the provided dir

Throws:

java.io.IOException - the IO exception during performing remote command

get

protected java.io.File get(org.springframework.messaging.Message<?> message,
                           Session<org.apache.commons.net.ftp.FTPFile> session,
                           java.lang.String remoteDir,
                           java.lang.String remoteFilePath,
                           java.lang.String remoteFilename,
                           org.apache.commons.net.ftp.FTPFile fileInfoParam)
                    throws java.io.IOException

Description copied from class: AbstractRemoteFileOutboundGateway

Copy a remote file to the configured local directory.

Overrides:

get in class AbstractRemoteFileOutboundGateway<org.apache.commons.net.ftp.FTPFile>

Parameters:

message - the message.

session - the session.

remoteDir - the remote directory.

remoteFilePath - the remote file path.

remoteFilename - the remote file name.

fileInfoParam - the remote file info; if null we will execute an 'ls' command first.

Returns:

The file.

Throws:

java.io.IOException - Any IOException.

mGet

protected java.util.List<java.io.File> mGet(org.springframework.messaging.Message<?> message,
                                            Session<org.apache.commons.net.ftp.FTPFile> session,
                                            java.lang.String remoteDirectory,
                                            java.lang.String remoteFilename)
                                     throws java.io.IOException

Overrides:

mGet in class AbstractRemoteFileOutboundGateway<org.apache.commons.net.ftp.FTPFile>

Throws:

java.io.IOException

rm

protected boolean rm(org.springframework.messaging.Message<?> message,
                     Session<org.apache.commons.net.ftp.FTPFile> session,
                     java.lang.String remoteFilePath)
              throws java.io.IOException

Description copied from class: AbstractRemoteFileOutboundGateway

Perform remote delete for the provided path. The message can be consulted to determine some context; isn't used in the default implementation.

Overrides:

rm in class AbstractRemoteFileOutboundGateway<org.apache.commons.net.ftp.FTPFile>

Parameters:

message - the request message related to the path to remove

session - the remote protocol session to perform remove command

remoteFilePath - the remote path to remove

Returns:

true or false as a result of the remote removal

Throws:

java.io.IOException - the IO exception during performing remote command

mv

protected boolean mv(org.springframework.messaging.Message<?> message,
                     Session<org.apache.commons.net.ftp.FTPFile> session,
                     java.lang.String remoteFilePath,
                     java.lang.String remoteFileNewPath)
              throws java.io.IOException

Description copied from class: AbstractRemoteFileOutboundGateway

Move one remote path to another. The message can be consulted to determine some context; isn't used in the default implementation.

Overrides:

mv in class AbstractRemoteFileOutboundGateway<org.apache.commons.net.ftp.FTPFile>

Parameters:

message - the request message related to this move command

session - the remote protocol session to perform move command

remoteFilePath - the source remote path

remoteFileNewPath - the target remote path

Returns:

true or false as a result of the operation

Throws:

java.io.IOException - the IO exception during performing remote command

put

protected java.lang.String put(org.springframework.messaging.Message<?> message,
                               Session<org.apache.commons.net.ftp.FTPFile> session,
                               java.lang.String subDirectory)

Description copied from class: AbstractRemoteFileOutboundGateway

Put the file based on the message to the remote server. The message can be consulted to determine some context. The session argument isn't used in the default implementation.

Overrides:

put in class AbstractRemoteFileOutboundGateway<org.apache.commons.net.ftp.FTPFile>

Parameters:

message - the request message related to this put command

session - the remote protocol session related to this invocation context

subDirectory - the target sub directory to put

Returns:

The remote path, or null if no local file was found.

mPut

protected java.util.List<java.lang.String> mPut(org.springframework.messaging.Message<?> message,
                                                Session<org.apache.commons.net.ftp.FTPFile> session,
                                                java.io.File localDir)

Description copied from class: AbstractRemoteFileOutboundGateway

Put files from the provided directory to the remote server recursively. The message can be consulted to determine some context. The session argument isn't used in the default implementation.

Overrides:

mPut in class AbstractRemoteFileOutboundGateway<org.apache.commons.net.ftp.FTPFile>

Parameters:

message - the request message related to this mPut command

session - the remote protocol session for this invocation context

localDir - the local directory to mput to the server

Returns:

The list of remote paths for sent files