org.springframework.cloud.fn.supplier.ftp

Class FtpSupplierConfiguration

java.lang.Object

org.springframework.cloud.fn.supplier.ftp.FtpSupplierConfiguration

@Configuration
 @EnableConfigurationProperties(value={FtpSupplierProperties.class,FileConsumerProperties.class})
 @Import(value=FtpSessionFactoryConfiguration.class)
public class FtpSupplierConfiguration
extends Object

Author:

David Turanski, Marius Bogoevici, Gary Russell, Artem Bilan, Christian Tzolov

Constructor Summary

Constructors

Constructor and Description
FtpSupplierConfiguration(FtpSupplierProperties ftpSupplierProperties, FileConsumerProperties fileConsumerProperties, org.springframework.integration.metadata.ConcurrentMetadataStore metadataStore, org.springframework.integration.file.remote.session.SessionFactory<org.apache.commons.net.ftp.FTPFile> ftpSessionFactory)

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Flux<org.springframework.messaging.Message<?>>	ftpMessageFlux()
org.springframework.integration.ftp.dsl.FtpInboundChannelAdapterSpec	ftpMessageSource()
org.reactivestreams.Publisher<org.springframework.messaging.Message<Object>>	ftpReadingFlow()
Supplier<reactor.core.publisher.Flux<org.springframework.messaging.Message<?>>>	ftpSupplier()

Methods inherited from class java.lang.Object

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

Constructor Detail

FtpSupplierConfiguration

public FtpSupplierConfiguration(FtpSupplierProperties ftpSupplierProperties,
                                FileConsumerProperties fileConsumerProperties,
                                org.springframework.integration.metadata.ConcurrentMetadataStore metadataStore,
                                org.springframework.integration.file.remote.session.SessionFactory<org.apache.commons.net.ftp.FTPFile> ftpSessionFactory)

Method Detail

ftpMessageSource

@Bean
public org.springframework.integration.ftp.dsl.FtpInboundChannelAdapterSpec ftpMessageSource()

ftpMessageFlux

@Bean
public reactor.core.publisher.Flux<org.springframework.messaging.Message<?>> ftpMessageFlux()

ftpReadingFlow

@Bean
 @ConditionalOnExpression(value="environment[\'file.consumer.mode\'] != \'ref\'")
public org.reactivestreams.Publisher<org.springframework.messaging.Message<Object>> ftpReadingFlow()

ftpSupplier

@Bean
public Supplier<reactor.core.publisher.Flux<org.springframework.messaging.Message<?>>> ftpSupplier()