Package org.springframework.integration.file.remote.gateway

Class AbstractRemoteFileOutboundGateway<F>

java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.handler.MessageHandlerSupport
org.springframework.integration.handler.AbstractMessageHandler
org.springframework.integration.handler.AbstractMessageProducingHandler
org.springframework.integration.handler.AbstractReplyProducingMessageHandler
org.springframework.integration.file.remote.gateway.AbstractRemoteFileOutboundGateway<F>
Type Parameters:
F - the file type.
All Implemented Interfaces:
org.reactivestreams.Subscriber<Message<?>>, Aware, BeanClassLoaderAware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Ordered, ExpressionCapable, Orderable, MessageProducer, HeaderPropagationAware, IntegrationPattern, NamedComponent, IntegrationManagement, TrackableComponent, MessageHandler, reactor.core.CoreSubscriber<Message<?>>
Direct Known Subclasses:
FtpOutboundGateway, SftpOutboundGateway, SmbOutboundGateway
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, Mauro Molinari

  • Constructor Details

    • AbstractRemoteFileOutboundGateway

      public AbstractRemoteFileOutboundGateway(SessionFactory<F> sessionFactory, MessageSessionCallback<F,?> 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.

    • AbstractRemoteFileOutboundGateway

      public AbstractRemoteFileOutboundGateway(RemoteFileTemplate<F> remoteFileTemplate, MessageSessionCallback<F,?> 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.

    • AbstractRemoteFileOutboundGateway

      public AbstractRemoteFileOutboundGateway(SessionFactory<F> sessionFactory, String command, @Nullable 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.

    • AbstractRemoteFileOutboundGateway

      public AbstractRemoteFileOutboundGateway(SessionFactory<F> sessionFactory, AbstractRemoteFileOutboundGateway.Command command, @Nullable 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.

    • AbstractRemoteFileOutboundGateway

      public AbstractRemoteFileOutboundGateway(RemoteFileTemplate<F> remoteFileTemplate, String command, @Nullable 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.

    • AbstractRemoteFileOutboundGateway

      public AbstractRemoteFileOutboundGateway(RemoteFileTemplate<F> remoteFileTemplate, AbstractRemoteFileOutboundGateway.Command command, @Nullable String expressionArg)
      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.
      expressionArg - the filename expression.

  • Method Details

    • remoteFileTemplateExplicitlySet

      protected final void remoteFileTemplateExplicitlySet(boolean remoteFileTemplateExplicitlySet)

    • assertRemoteFileTemplateMutability

      protected void assertRemoteFileTemplateMutability(String propertyName)

    • setOptions

      public void setOptions(String options)
      Specify the options for various gateway commands as a space-delimited string.
      Parameters:
      options - the options to set
      See Also:

    • setOption

      public void setOption(AbstractRemoteFileOutboundGateway.Option... options)
      Specify the array of options for various gateway commands.
      Parameters:
      options - the AbstractRemoteFileOutboundGateway.Option array to use.
      Since:
      5.0
      See Also:

    • setRemoteFileSeparator

      public void setRemoteFileSeparator(String remoteFileSeparator)
      Set the file separator when dealing with remote files; default '/'.
      Parameters:
      remoteFileSeparator - the separator.
      See Also:

    • setLocalDirectory

      public void setLocalDirectory(File localDirectory)
      Specify a directory path where remote files will be transferred to.
      Parameters:
      localDirectory - the localDirectory to set

    • setLocalDirectoryExpression

      public void setLocalDirectoryExpression(Expression localDirectoryExpression)
      Specify a SpEL expression to evaluate the directory path to which remote files will be transferred.
      Parameters:
      localDirectoryExpression - the SpEL to determine the local directory.

    • setLocalDirectoryExpressionString

      public void setLocalDirectoryExpressionString(String localDirectoryExpression)
      Specify a SpEL expression to evaluate the directory path to which remote files will be transferred.
      Parameters:
      localDirectoryExpression - the SpEL to determine the local directory.
      Since:
      5.0

    • setAutoCreateLocalDirectory

      public void setAutoCreateLocalDirectory(boolean autoCreateLocalDirectory)
      A boolean flag to identify if local directory should be created automatically. Defaults to true.
      Parameters:
      autoCreateLocalDirectory - the autoCreateLocalDirectory to set

    • setTemporaryFileSuffix

      public void setTemporaryFileSuffix(String temporaryFileSuffix)
      Set the temporary suffix to use when transferring files to the remote system. Default .writing.
      Parameters:
      temporaryFileSuffix - the temporaryFileSuffix to set
      See Also:

    • setAutoCreateDirectory

      public void setAutoCreateDirectory(boolean autoCreateDirectory)
      Determine whether the remote directory should automatically be created when sending files to the remote system.
      Parameters:
      autoCreateDirectory - true to create the directory.
      Since:
      5.2
      See Also:

    • setRemoteDirectoryExpression

      public void setRemoteDirectoryExpression(Expression remoteDirectoryExpression)
      Set the remote directory expression used to determine the remote directory to which files will be sent.
      Parameters:
      remoteDirectoryExpression - the remote directory expression.
      Since:
      5.2
      See Also:

    • setTemporaryRemoteDirectoryExpression

      public void setTemporaryRemoteDirectoryExpression(Expression temporaryRemoteDirectoryExpression)
      Set a temporary remote directory expression; used when transferring files to the remote system. After a successful transfer the file is renamed using the remoteDirectoryExpression.
      Parameters:
      temporaryRemoteDirectoryExpression - the temporary remote directory expression.
      Since:
      5.2
      See Also:

    • setFileNameExpression

      public void setFileNameExpression(Expression fileNameExpression)
      Set the file name expression to determine the full path to the remote file.
      Parameters:
      fileNameExpression - the file name expression.
      Since:
      5.2
      See Also:

    • setUseTemporaryFileName

      public void setUseTemporaryFileName(boolean useTemporaryFileName)
      Set whether a temporary file name is used when sending files to the remote system.
      Parameters:
      useTemporaryFileName - true to use a temporary file name.
      Since:
      5.2
      See Also:

    • setFileNameGenerator

      public void setFileNameGenerator(FileNameGenerator fileNameGenerator)
      Set the file name generator used to generate the remote filename to be used when transferring files to the remote system.
      Parameters:
      fileNameGenerator - the file name generator.
      Since:
      5.2
      See Also:

    • setCharset

      public void setCharset(String charset)
      Set the charset to use when converting String payloads to bytes as the content of the remote file. Default UTF-8.
      Parameters:
      charset - the charset.
      Since:
      5.2
      See Also:

    • setFilter

      public void setFilter(FileListFilter<F> filter)
      Set a FileListFilter to filter remote files.
      Parameters:
      filter - the filter to set

    • setMputFilter

      public void setMputFilter(FileListFilter<File> filter)
      A FileListFilter that runs against the local file system view when using MPUT command.
      Parameters:
      filter - the filter to set

    • setRenameExpression

      public void setRenameExpression(Expression renameExpression)
      Specify a SpEL expression for files renaming during transfer.
      Parameters:
      renameExpression - the expression to use.
      Since:
      4.3

    • setRenameExpressionString

      public void setRenameExpressionString(String renameExpression)
      Specify a SpEL expression for files renaming during transfer.
      Parameters:
      renameExpression - the String in SpEL syntax.
      Since:
      4.3

    • setLocalFilenameGeneratorExpression

      public void setLocalFilenameGeneratorExpression(Expression localFilenameGeneratorExpression)
      Specify a SpEL expression for local files renaming after downloading.
      Parameters:
      localFilenameGeneratorExpression - the expression to use.
      Since:
      3.0

    • setLocalFilenameGeneratorExpressionString

      public void setLocalFilenameGeneratorExpressionString(String localFilenameGeneratorExpression)
      Specify a SpEL expression for local files renaming after downloading.
      Parameters:
      localFilenameGeneratorExpression - the String in SpEL syntax.
      Since:
      4.3

    • setFileExistsMode

      public void setFileExistsMode(FileExistsMode fileExistsMode)
      Determine the action to take when using GET and MGET operations when the file already exists locally, or PUT and MPUT when the file exists on the remote system.
      Parameters:
      fileExistsMode - the fileExistsMode to set.
      Since:
      4.2

    • setChmodOctal

      public void setChmodOctal(String chmod)
      String setter for Spring XML convenience.
      Parameters:
      chmod - permissions as an octal string e.g "600";
      Since:
      4.3
      See Also:

    • setChmod

      public void setChmod(int chmod)
      Set the file permissions after uploading, e.g. 0600 for owner read/write.
      Parameters:
      chmod - the permissions.
      Since:
      4.3

    • isChmodCapable

      public boolean isChmodCapable()

    • getRemoteFileTemplate

      protected final RemoteFileTemplate<F> getRemoteFileTemplate()

    • doInit

      protected void doInit()
      Overrides:
      doInit in class AbstractReplyProducingMessageHandler

    • handleRequestMessage

      protected 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
      Parameters:
      requestMessage - The request message.
      Returns:
      The result of handling the message, or null.

    • nlst

      protected List<String> nlst(Message<?> message, Session<F> session, String dir) throws IOException
      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.
      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:
      IOException - the IO exception during performing remote command
      Since:
      5.0

    • rm

      protected boolean rm(Message<?> message, Session<F> session, String remoteFilePath) throws IOException
      Perform remote delete for the provided path. The message can be consulted to determine some context; isn't used in the default implementation.
      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:
      IOException - the IO exception during performing remote command
      Since:
      5.0

    • mv

      protected boolean mv(Message<?> message, Session<F> session, String remoteFilePath, String remoteFileNewPath) throws IOException
      Move one remote path to another. The message can be consulted to determine some context; isn't used in the default implementation.
      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:
      IOException - the IO exception during performing remote command
      Since:
      5.0

    • put

      protected String put(Message<?> message, Session<F> session, String subDirectory)
      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.
      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.
      Since:
      5.0

    • doChmod

      protected void doChmod(RemoteFileOperations<F> remoteFileOperations, String path, int chmodToSet)
      Set the mode on the remote file after transfer; the default implementation does nothing.
      Parameters:
      remoteFileOperations - the remote file template.
      path - the path.
      chmodToSet - the chmod to set.
      Since:
      4.3

    • mPut

      protected List<String> mPut(Message<?> message, Session<F> session, File localDir)
      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.
      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
      Since:
      5.0

    • ls

      protected List<?> ls(Message<?> message, Session<F> session, String dir) throws IOException
      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.
      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:
      IOException - the IO exception during performing remote command

    • filterFiles

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

    • filterFile

      protected final F filterFile(F file)

    • filterMputFiles

      protected final List<File> filterMputFiles(File[] files)

    • purgeLinks

      protected void purgeLinks(List<F> lsFiles)

    • purgeDots

      protected void purgeDots(List<F> lsFiles)

    • get

      protected File get(Message<?> message, Session<F> session, String remoteDir, String remoteFilePath, String remoteFilename, F fileInfoParam) throws IOException
      Copy a remote file to the configured local directory.
      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:
      IOException - Any IOException.

    • mGet

      protected List<File> mGet(Message<?> message, Session<F> session, String remoteDirectory, String remoteFilename) throws IOException
      Throws:
      IOException

    • getRemoteFilename

      protected String getRemoteFilename(String remoteFilePath)
      Parameters:
      remoteFilePath - The remote file path.
      Returns:
      The remote file name.

    • isDirectory

      protected abstract boolean isDirectory(F file)

    • isLink

      protected abstract boolean isLink(F file)

    • getFilename

      protected abstract String getFilename(F file)

    • getFilename

      protected abstract String getFilename(AbstractFileInfo<F> file)

    • getModified

      protected abstract long getModified(F file)

    • asFileInfoList

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

    • enhanceNameWithSubDirectory

      protected abstract F enhanceNameWithSubDirectory(F file, String directory)