Package org.springframework.cloud.fn.supplier.sftp

Class SftpSupplierConfiguration

java.lang.Object
org.springframework.cloud.fn.supplier.sftp.SftpSupplierConfiguration
@Configuration @EnableConfigurationProperties({SftpSupplierProperties.class,FileConsumerProperties.class}) @Import(SftpSupplierFactoryConfiguration.class) public class SftpSupplierConfiguration extends Object
Author:
Gary Russell, Artem Bilan, Chris Schaefer, Christian Tzolov, David Turanski, Corneil du Plessis

  • Constructor Details

    • SftpSupplierConfiguration

      public SftpSupplierConfiguration()

  • Method Details

    • subscriptionBarrier

      @Bean public reactor.core.publisher.MonoProcessor<Boolean> subscriptionBarrier()

    • sftpSupplier

      @Bean public Supplier<reactor.core.publisher.Flux<? extends Message<?>>> sftpSupplier(org.springframework.integration.core.MessageSource<?> sftpMessageSource, @Nullable org.reactivestreams.Publisher<Message<Object>> sftpReadingFlow, reactor.core.publisher.MonoProcessor<Boolean> subscriptionBarrier, SftpSupplierProperties sftpSupplierProperties)

    • sftpMessageSource

      @Bean @Primary public org.springframework.integration.core.MessageSource<?> sftpMessageSource(org.springframework.integration.core.MessageSource<?> messageSource, BeanFactory beanFactory, @Nullable List<org.springframework.integration.aop.ReceiveMessageAdvice> receiveMessageAdvice)

    • chainFilter

      @Bean public org.springframework.integration.file.filters.FileListFilter<org.apache.sshd.sftp.client.SftpClient.DirEntry> chainFilter(SftpSupplierProperties sftpSupplierProperties, org.springframework.integration.metadata.ConcurrentMetadataStore metadataStore)