Package org.springframework.cloud.fn.supplier.sftp

Class SftpSupplierRotator

java.lang.Object
org.springframework.integration.file.remote.aop.RotatingServerAdvice
org.springframework.cloud.fn.supplier.sftp.SftpSupplierRotator
All Implemented Interfaces:
Advice, Interceptor, MethodInterceptor, org.springframework.integration.aop.MessageSourceMutator, org.springframework.integration.aop.ReceiveMessageAdvice
public class SftpSupplierRotator extends org.springframework.integration.file.remote.aop.RotatingServerAdvice
An RotatingServerAdvice for listing files on multiple directories/servers.
Since:
2.0
Author:
Gary Russell, David Turanski

  • Constructor Summary

    Constructors
    Constructor
    Description
    SftpSupplierRotator(SftpSupplierProperties properties, org.springframework.integration.file.remote.aop.StandardRotationPolicy rotationPolicy)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    Message<?>
    afterReceive(Message<?> result, org.springframework.integration.core.MessageSource<?> source)
     
    String
    getCurrentDirectory()
     
    String
    getCurrentKey()
     

    Methods inherited from class org.springframework.integration.file.remote.aop.RotatingServerAdvice

    beforeReceive

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.springframework.integration.aop.MessageSourceMutator

    afterReceive, beforeReceive

    Methods inherited from interface org.springframework.integration.aop.ReceiveMessageAdvice

    invoke

  • Constructor Details

    • SftpSupplierRotator

      public SftpSupplierRotator(SftpSupplierProperties properties, org.springframework.integration.file.remote.aop.StandardRotationPolicy rotationPolicy)

  • Method Details

    • getCurrentKey

      public String getCurrentKey()

    • getCurrentDirectory

      public String getCurrentDirectory()

    • afterReceive

      public Message<?> afterReceive(Message<?> result, org.springframework.integration.core.MessageSource<?> source)
      Specified by:
      afterReceive in interface org.springframework.integration.aop.MessageSourceMutator
      Overrides:
      afterReceive in class org.springframework.integration.file.remote.aop.RotatingServerAdvice