org.springframework.cloud.fn.supplier.file

Class FileSupplierConfiguration

java.lang.Object

org.springframework.cloud.fn.supplier.file.FileSupplierConfiguration

@Configuration
 @EnableConfigurationProperties(value={FileSupplierProperties.class,FileConsumerProperties.class})
public class FileSupplierConfiguration
extends Object

Author:

Artem Bilan, Soby Chacko

Constructor Summary

Constructors

Constructor and Description
FileSupplierConfiguration(FileSupplierProperties fileSupplierProperties, FileConsumerProperties fileConsumerProperties)

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Flux<org.springframework.messaging.Message<?>>	fileMessageFlux()
org.springframework.integration.file.dsl.FileInboundChannelAdapterSpec	fileMessageSource()
org.reactivestreams.Publisher<org.springframework.messaging.Message<Object>>	fileReadingFlow()
Supplier<reactor.core.publisher.Flux<org.springframework.messaging.Message<?>>>	fileSupplier()

Methods inherited from class java.lang.Object

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

Constructor Detail

FileSupplierConfiguration

public FileSupplierConfiguration(FileSupplierProperties fileSupplierProperties,
                                 FileConsumerProperties fileConsumerProperties)

Method Detail

fileMessageSource

@Bean
public org.springframework.integration.file.dsl.FileInboundChannelAdapterSpec fileMessageSource()

fileMessageFlux

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

fileReadingFlow

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

fileSupplier

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