@Configuration @EnableConfigurationProperties(value={SftpSupplierProperties.class,FileConsumerProperties.class}) @Import(value=SftpSupplierFactoryConfiguration.class) public class SftpSupplierConfiguration extends Object
Constructor and Description |
---|
SftpSupplierConfiguration() |
Modifier and Type | Method and Description |
---|---|
org.springframework.integration.file.filters.FileListFilter<com.jcraft.jsch.ChannelSftp.LsEntry> |
chainFilter(SftpSupplierProperties sftpSupplierProperties,
org.springframework.integration.metadata.ConcurrentMetadataStore metadataStore) |
org.springframework.integration.core.MessageSource<?> |
sftpMessageSource(org.springframework.integration.core.MessageSource<?> messageSource,
org.springframework.beans.factory.BeanFactory beanFactory,
List<org.springframework.integration.aop.ReceiveMessageAdvice> receiveMessageAdvice) |
Supplier<reactor.core.publisher.Flux<? extends org.springframework.messaging.Message<?>>> |
sftpSupplier(org.springframework.integration.core.MessageSource<?> sftpMessageSource,
org.reactivestreams.Publisher<org.springframework.messaging.Message<Object>> sftpReadingFlow,
reactor.core.publisher.MonoProcessor<Boolean> subscriptionBarrier,
SftpSupplierProperties sftpSupplierProperties) |
reactor.core.publisher.MonoProcessor<Boolean> |
subscriptionBarrier() |
@Bean public reactor.core.publisher.MonoProcessor<Boolean> subscriptionBarrier()
@Bean public Supplier<reactor.core.publisher.Flux<? extends org.springframework.messaging.Message<?>>> sftpSupplier(org.springframework.integration.core.MessageSource<?> sftpMessageSource, @Nullable org.reactivestreams.Publisher<org.springframework.messaging.Message<Object>> sftpReadingFlow, reactor.core.publisher.MonoProcessor<Boolean> subscriptionBarrier, SftpSupplierProperties sftpSupplierProperties)
@Bean @Primary public org.springframework.integration.core.MessageSource<?> sftpMessageSource(org.springframework.integration.core.MessageSource<?> messageSource, org.springframework.beans.factory.BeanFactory beanFactory, @Nullable List<org.springframework.integration.aop.ReceiveMessageAdvice> receiveMessageAdvice)
@Bean public org.springframework.integration.file.filters.FileListFilter<com.jcraft.jsch.ChannelSftp.LsEntry> chainFilter(SftpSupplierProperties sftpSupplierProperties, org.springframework.integration.metadata.ConcurrentMetadataStore metadataStore)
Copyright © 2022. All rights reserved.