@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.springframework.integration.file.filters.FileListFilter<File> fileListFilter,
org.springframework.cloud.fn.common.config.ComponentCustomizer<org.springframework.integration.file.dsl.FileInboundChannelAdapterSpec> fileInboundChannelAdapterSpecCustomizer) |
org.reactivestreams.Publisher<org.springframework.messaging.Message<Object>> |
fileReadingFlow() |
Supplier<reactor.core.publisher.Flux<org.springframework.messaging.Message<?>>> |
fileSupplier() |
org.springframework.integration.file.filters.ChainFileListFilter<File> |
filter(org.springframework.integration.metadata.ConcurrentMetadataStore metadataStore) |
public FileSupplierConfiguration(FileSupplierProperties fileSupplierProperties, FileConsumerProperties fileConsumerProperties)
@Bean public org.springframework.integration.file.filters.ChainFileListFilter<File> filter(org.springframework.integration.metadata.ConcurrentMetadataStore metadataStore)
@Bean public org.springframework.integration.file.dsl.FileInboundChannelAdapterSpec fileMessageSource(org.springframework.integration.file.filters.FileListFilter<File> fileListFilter, @Nullable org.springframework.cloud.fn.common.config.ComponentCustomizer<org.springframework.integration.file.dsl.FileInboundChannelAdapterSpec> fileInboundChannelAdapterSpecCustomizer)
@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 © 2022. All rights reserved.