@Configuration @EnableConfigurationProperties(value={FileSupplierProperties.class,FileConsumerProperties.class}) public class FileSupplierConfiguration extends Object
Constructor and Description |
---|
FileSupplierConfiguration(FileSupplierProperties fileSupplierProperties,
FileConsumerProperties fileConsumerProperties) |
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() |
public FileSupplierConfiguration(FileSupplierProperties fileSupplierProperties, FileConsumerProperties fileConsumerProperties)
@Bean public org.springframework.integration.file.dsl.FileInboundChannelAdapterSpec fileMessageSource()
@Bean public reactor.core.publisher.Flux<org.springframework.messaging.Message<?>> fileMessageFlux()
@Bean @ConditionalOnExpression(value="environment[\'file.consumer.mode\'] != \'ref\'") public org.reactivestreams.Publisher<org.springframework.messaging.Message<Object>> fileReadingFlow()
@Bean public Supplier<reactor.core.publisher.Flux<org.springframework.messaging.Message<?>>> fileSupplier()
Copyright © 2020. All rights reserved.