org.springframework.integration.sftp.gateway

Class SftpOutboundGateway

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<com.jcraft.jsch.ChannelSftp.LsEntry>

org.springframework.integration.sftp.gateway.SftpOutboundGateway

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 SftpOutboundGateway
extends AbstractRemoteFileOutboundGateway<com.jcraft.jsch.ChannelSftp.LsEntry>

Outbound Gateway for performing remote file operations via SFTP.

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
SftpOutboundGateway(RemoteFileTemplate<com.jcraft.jsch.ChannelSftp.LsEntry> remoteFileTemplate, MessageSessionCallback<com.jcraft.jsch.ChannelSftp.LsEntry,?> messageSessionCallback) Construct an instance with the supplied remote file template and callback for performing operations on the session.
SftpOutboundGateway(RemoteFileTemplate<com.jcraft.jsch.ChannelSftp.LsEntry> 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.
SftpOutboundGateway(SessionFactory<com.jcraft.jsch.ChannelSftp.LsEntry> sessionFactory, MessageSessionCallback<com.jcraft.jsch.ChannelSftp.LsEntry,?> messageSessionCallback) Construct an instance using the provided session factory and callback for performing operations on the session.
SftpOutboundGateway(SessionFactory<com.jcraft.jsch.ChannelSftp.LsEntry> 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<com.jcraft.jsch.ChannelSftp.LsEntry>>	asFileInfoList(java.util.Collection<com.jcraft.jsch.ChannelSftp.LsEntry> files)
protected void	doChmod(RemoteFileOperations<com.jcraft.jsch.ChannelSftp.LsEntry> remoteFileOperations, java.lang.String path, int chmod) Set the mode on the remote file after transfer; the default implementation does nothing.
protected com.jcraft.jsch.ChannelSftp.LsEntry	enhanceNameWithSubDirectory(com.jcraft.jsch.ChannelSftp.LsEntry file, java.lang.String directory)
java.lang.String	getComponentType() Subclasses may implement this method to provide component type information.
protected java.lang.String	getFilename(AbstractFileInfo<com.jcraft.jsch.ChannelSftp.LsEntry> file)
protected java.lang.String	getFilename(com.jcraft.jsch.ChannelSftp.LsEntry file)
protected long	getModified(com.jcraft.jsch.ChannelSftp.LsEntry file)
boolean	isChmodCapable()
protected boolean	isDirectory(com.jcraft.jsch.ChannelSftp.LsEntry file)
protected boolean	isLink(com.jcraft.jsch.ChannelSftp.LsEntry file)

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

doInit, filterFiles, filterMputFiles, get, getRemoteFilename, handleRequestMessage, ls, mGet, mPut, mv, nlst, purgeDots, purgeLinks, put, rm, 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, isInitialized, 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

SftpOutboundGateway

public SftpOutboundGateway(SessionFactory<com.jcraft.jsch.ChannelSftp.LsEntry> sessionFactory,
                           MessageSessionCallback<com.jcraft.jsch.ChannelSftp.LsEntry,?> 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.

SftpOutboundGateway

public SftpOutboundGateway(RemoteFileTemplate<com.jcraft.jsch.ChannelSftp.LsEntry> remoteFileTemplate,
                           MessageSessionCallback<com.jcraft.jsch.ChannelSftp.LsEntry,?> 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.

SftpOutboundGateway

public SftpOutboundGateway(SessionFactory<com.jcraft.jsch.ChannelSftp.LsEntry> 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.

SftpOutboundGateway

public SftpOutboundGateway(RemoteFileTemplate<com.jcraft.jsch.ChannelSftp.LsEntry> 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.

Method Detail

isDirectory

protected boolean isDirectory(com.jcraft.jsch.ChannelSftp.LsEntry file)

Specified by:

isDirectory in class AbstractRemoteFileOutboundGateway<com.jcraft.jsch.ChannelSftp.LsEntry>

isLink

protected boolean isLink(com.jcraft.jsch.ChannelSftp.LsEntry file)

Specified by:

isLink in class AbstractRemoteFileOutboundGateway<com.jcraft.jsch.ChannelSftp.LsEntry>

getFilename

protected java.lang.String getFilename(com.jcraft.jsch.ChannelSftp.LsEntry file)

Specified by:

getFilename in class AbstractRemoteFileOutboundGateway<com.jcraft.jsch.ChannelSftp.LsEntry>

getFilename

protected java.lang.String getFilename(AbstractFileInfo<com.jcraft.jsch.ChannelSftp.LsEntry> file)

Specified by:

getFilename in class AbstractRemoteFileOutboundGateway<com.jcraft.jsch.ChannelSftp.LsEntry>

asFileInfoList

protected java.util.List<AbstractFileInfo<com.jcraft.jsch.ChannelSftp.LsEntry>> asFileInfoList(java.util.Collection<com.jcraft.jsch.ChannelSftp.LsEntry> files)

Specified by:

asFileInfoList in class AbstractRemoteFileOutboundGateway<com.jcraft.jsch.ChannelSftp.LsEntry>

getModified

protected long getModified(com.jcraft.jsch.ChannelSftp.LsEntry file)

Specified by:

getModified in class AbstractRemoteFileOutboundGateway<com.jcraft.jsch.ChannelSftp.LsEntry>

enhanceNameWithSubDirectory

protected com.jcraft.jsch.ChannelSftp.LsEntry enhanceNameWithSubDirectory(com.jcraft.jsch.ChannelSftp.LsEntry file,
                                                                          java.lang.String directory)

Specified by:

enhanceNameWithSubDirectory in class AbstractRemoteFileOutboundGateway<com.jcraft.jsch.ChannelSftp.LsEntry>

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

isChmodCapable

public boolean isChmodCapable()

Overrides:

isChmodCapable in class AbstractRemoteFileOutboundGateway<com.jcraft.jsch.ChannelSftp.LsEntry>

doChmod

protected void doChmod(RemoteFileOperations<com.jcraft.jsch.ChannelSftp.LsEntry> remoteFileOperations,
                       java.lang.String path,
                       int chmod)

Description copied from class: AbstractRemoteFileOutboundGateway

Set the mode on the remote file after transfer; the default implementation does nothing.

Overrides:

doChmod in class AbstractRemoteFileOutboundGateway<com.jcraft.jsch.ChannelSftp.LsEntry>

Parameters:

remoteFileOperations - the remote file template.

path - the path.

chmod - the chmod to set.