org.springframework.integration.file.filters.FileListFilter<com.jcraft.jsch.ChannelSftp.LsEntry> |
SftpSupplierConfiguration.chainFilter(SftpSupplierProperties sftpSupplierProperties,
org.springframework.integration.metadata.ConcurrentMetadataStore metadataStore) |
SftpSupplierFactoryConfiguration.DelegatingFactoryWrapper |
SftpSupplierFactoryConfiguration.delegatingFactoryWrapper(SftpSupplierProperties properties,
org.springframework.integration.file.remote.session.SessionFactory<com.jcraft.jsch.ChannelSftp.LsEntry> defaultFactory,
org.springframework.beans.factory.BeanFactory beanFactory) |
SftpSupplierRotator |
SftpSupplierFactoryConfiguration.rotatingAdvice(SftpSupplierProperties properties,
org.springframework.integration.file.remote.aop.StandardRotationPolicy rotationPolicy) |
org.springframework.integration.file.remote.session.SessionFactory<com.jcraft.jsch.ChannelSftp.LsEntry> |
SftpSupplierFactoryConfiguration.sftpSessionFactory(SftpSupplierProperties properties,
org.springframework.beans.factory.BeanFactory beanFactory) |
Supplier<reactor.core.publisher.Flux<? extends org.springframework.messaging.Message<?>>> |
SftpSupplierConfiguration.sftpSupplier(org.springframework.integration.core.MessageSource<?> sftpMessageSource,
org.reactivestreams.Publisher<org.springframework.messaging.Message<Object>> sftpReadingFlow,
reactor.core.publisher.MonoProcessor<Boolean> subscriptionBarrier,
SftpSupplierProperties sftpSupplierProperties) |