Package org.springframework.cloud.fn.supplier.file

Class FileSupplierConfiguration

java.lang.Object
org.springframework.cloud.fn.supplier.file.FileSupplierConfiguration
@Configuration @EnableConfigurationProperties({FileSupplierProperties.class,FileConsumerProperties.class}) public class FileSupplierConfiguration extends Object
Author:
Artem Bilan, Soby Chacko

  • Constructor Details

  • Method Details

    • filter

      @Bean public org.springframework.integration.file.filters.ChainFileListFilter<File> filter(org.springframework.integration.metadata.ConcurrentMetadataStore metadataStore)

    • fileMessageSource

      @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)

    • fileMessageFlux

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

    • fileReadingFlow

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

    • fileSupplier

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