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:

org.aopalliance.aop.Advice, org.aopalliance.intercept.Interceptor, org.aopalliance.intercept.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 and Description
SftpSupplierRotator(SftpSupplierProperties properties, org.springframework.integration.file.remote.aop.StandardRotationPolicy rotationPolicy)

Method Summary

Modifier and Type	Method and Description
org.springframework.messaging.Message<?>	afterReceive(org.springframework.messaging.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 Detail

SftpSupplierRotator

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

Method Detail

getCurrentKey

public String getCurrentKey()

getCurrentDirectory

public String getCurrentDirectory()

afterReceive

public org.springframework.messaging.Message<?> afterReceive(org.springframework.messaging.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