org.springframework.integration.file.remote.gateway

Class AbstractRemoteFileOutboundGateway<F>

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.handler.AbstractMessageHandler

org.springframework.integration.handler.AbstractReplyProducingMessageHandler

org.springframework.integration.file.remote.gateway.AbstractRemoteFileOutboundGateway<F>

All Implemented Interfaces:

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, Orderable, MessageHandler, MessageProducer, TrackableComponent, NamedComponent

Direct Known Subclasses:

FtpOutboundGateway, SftpOutboundGateway

public abstract class AbstractRemoteFileOutboundGateway<F>
extends AbstractReplyProducingMessageHandler

Base class for Outbound Gateways that perform remote file operations.

Since:

2.1

Author:

Gary Russell, Artem Bilan

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AbstractRemoteFileOutboundGateway.Command Enumeration of commands supported by the gateways.
static class	AbstractRemoteFileOutboundGateway.Option Enumeration of options supported by various commands.

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

AbstractReplyProducingMessageHandler.RequestHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected AbstractRemoteFileOutboundGateway.Command	command
protected java.util.Set<AbstractRemoteFileOutboundGateway.Option>	options

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

logger

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor and Description
AbstractRemoteFileOutboundGateway(RemoteFileTemplate<F> remoteFileTemplate, AbstractRemoteFileOutboundGateway.Command command, java.lang.String expression)
AbstractRemoteFileOutboundGateway(RemoteFileTemplate<F> remoteFileTemplate, java.lang.String command, java.lang.String expression)
AbstractRemoteFileOutboundGateway(SessionFactory<F> sessionFactory, AbstractRemoteFileOutboundGateway.Command command, java.lang.String expression)
AbstractRemoteFileOutboundGateway(SessionFactory<F> sessionFactory, java.lang.String command, java.lang.String expression)

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract java.util.List<AbstractFileInfo<F>>	asFileInfoList(java.util.Collection<F> files)
protected void	doInit()
protected abstract F	enhanceNameWithSubDirectory(F file, java.lang.String directory)
protected java.util.List<F>	filterFiles(F[] files)
protected java.util.List<java.io.File>	filterMputFiles(java.io.File[] files)
protected java.io.File	get(Message<?> message, Session<F> session, java.lang.String remoteDir, java.lang.String remoteFilePath, java.lang.String remoteFilename, boolean lsFirst) Copy a remote file to the configured local directory.
protected abstract java.lang.String	getFilename(AbstractFileInfo<F> file)
protected abstract java.lang.String	getFilename(F file)
protected abstract long	getModified(F file)
protected java.lang.String	getRemoteFilename(java.lang.String remoteFilePath)
protected java.lang.Object	handleRequestMessage(Message<?> requestMessage) Subclasses must implement this method to handle the request Message.
protected abstract boolean	isDirectory(F file)
protected abstract boolean	isLink(F file)
protected java.util.List<?>	ls(Session<F> session, java.lang.String dir)
protected java.util.List<java.io.File>	mGet(Message<?> message, Session<F> session, java.lang.String remoteDirectory, java.lang.String remoteFilename)
protected void	purgeDots(java.util.List<F> lsFiles)
protected void	purgeLinks(java.util.List<F> lsFiles)
void	setAutoCreateLocalDirectory(boolean autoCreateLocalDirectory)
void	setFilter(FileListFilter<F> filter)
void	setLocalDirectory(java.io.File localDirectory)
void	setLocalDirectoryExpression(org.springframework.expression.Expression localDirectoryExpression)
void	setLocalFilenameGeneratorExpression(org.springframework.expression.Expression localFilenameGeneratorExpression)
void	setMputFilter(FileListFilter<java.io.File> filter)
void	setOptions(java.lang.String options)
void	setRemoteFileSeparator(java.lang.String remoteFileSeparator)
void	setRenameExpression(java.lang.String expression)
void	setTemporaryFileSuffix(java.lang.String temporaryFileSuffix)

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

doInvokeAdvisedRequestHandler, getMessagingTemplate, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader, setChannelResolver, setOutputChannel, setRequiresReply, setSendTimeout, shouldCopyRequestHeaders

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

getComponentType, getOrder, handleMessage, setOrder, setShouldTrack

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

afterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, 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

Field Detail

command

protected final AbstractRemoteFileOutboundGateway.Command command

options

protected volatile java.util.Set<AbstractRemoteFileOutboundGateway.Option> options

Constructor Detail

AbstractRemoteFileOutboundGateway

public AbstractRemoteFileOutboundGateway(SessionFactory<F> sessionFactory,
                                 java.lang.String command,
                                 java.lang.String expression)

AbstractRemoteFileOutboundGateway

public AbstractRemoteFileOutboundGateway(SessionFactory<F> sessionFactory,
                                 AbstractRemoteFileOutboundGateway.Command command,
                                 java.lang.String expression)

AbstractRemoteFileOutboundGateway

public AbstractRemoteFileOutboundGateway(RemoteFileTemplate<F> remoteFileTemplate,
                                 java.lang.String command,
                                 java.lang.String expression)

AbstractRemoteFileOutboundGateway

public AbstractRemoteFileOutboundGateway(RemoteFileTemplate<F> remoteFileTemplate,
                                 AbstractRemoteFileOutboundGateway.Command command,
                                 java.lang.String expression)

Method Detail

setOptions

public void setOptions(java.lang.String options)

Parameters:

options - the options to set

setRemoteFileSeparator

public void setRemoteFileSeparator(java.lang.String remoteFileSeparator)

Parameters:

remoteFileSeparator - the remoteFileSeparator to set

setLocalDirectory

public void setLocalDirectory(java.io.File localDirectory)

Parameters:

localDirectory - the localDirectory to set

setLocalDirectoryExpression

public void setLocalDirectoryExpression(org.springframework.expression.Expression localDirectoryExpression)

setAutoCreateLocalDirectory

public void setAutoCreateLocalDirectory(boolean autoCreateLocalDirectory)

Parameters:

autoCreateLocalDirectory - the autoCreateLocalDirectory to set

setTemporaryFileSuffix

public void setTemporaryFileSuffix(java.lang.String temporaryFileSuffix)

Parameters:

temporaryFileSuffix - the temporaryFileSuffix to set

setFilter

public void setFilter(FileListFilter<F> filter)

Parameters:

filter - the filter to set

setMputFilter

public void setMputFilter(FileListFilter<java.io.File> filter)

Parameters:

filter - the filter to set

setRenameExpression

public void setRenameExpression(java.lang.String expression)

setLocalFilenameGeneratorExpression

public void setLocalFilenameGeneratorExpression(org.springframework.expression.Expression localFilenameGeneratorExpression)

doInit

protected void doInit()

Overrides:

doInit in class AbstractReplyProducingMessageHandler

handleRequestMessage

protected java.lang.Object handleRequestMessage(Message<?> requestMessage)

Description copied from class: AbstractReplyProducingMessageHandler

Subclasses must implement this method to handle the request Message. The return value may be a Message, a MessageBuilder, or any plain Object. The base class will handle the final creation of a reply Message from any of those starting points. If the return value is null, the Message flow will end here.

Specified by:

handleRequestMessage in class AbstractReplyProducingMessageHandler

ls

protected java.util.List<?> ls(Session<F> session,
                   java.lang.String dir)
                        throws java.io.IOException

Throws:

java.io.IOException

filterFiles

protected final java.util.List<F> filterFiles(F[] files)

filterMputFiles

protected final java.util.List<java.io.File> filterMputFiles(java.io.File[] files)

purgeLinks

protected void purgeLinks(java.util.List<F> lsFiles)

purgeDots

protected void purgeDots(java.util.List<F> lsFiles)

get

protected java.io.File get(Message<?> message,
               Session<F> session,
               java.lang.String remoteDir,
               java.lang.String remoteFilePath,
               java.lang.String remoteFilename,
               boolean lsFirst)
                    throws java.io.IOException

Copy a remote file to the configured local directory.

Parameters:

message -

session -

remoteDir -

remoteFilePath - @throws IOException

Throws:

java.io.IOException

mGet

protected java.util.List<java.io.File> mGet(Message<?> message,
                                Session<F> session,
                                java.lang.String remoteDirectory,
                                java.lang.String remoteFilename)
                                     throws java.io.IOException

Throws:

java.io.IOException

getRemoteFilename

protected java.lang.String getRemoteFilename(java.lang.String remoteFilePath)

Parameters:

remoteFilePath -

isDirectory

protected abstract boolean isDirectory(F file)

isLink

protected abstract boolean isLink(F file)

getFilename

protected abstract java.lang.String getFilename(F file)

getFilename

protected abstract java.lang.String getFilename(AbstractFileInfo<F> file)

getModified

protected abstract long getModified(F file)

asFileInfoList

protected abstract java.util.List<AbstractFileInfo<F>> asFileInfoList(java.util.Collection<F> files)

enhanceNameWithSubDirectory

protected abstract F enhanceNameWithSubDirectory(F file,
                            java.lang.String directory)