org.springframework.cloud.stream.app.sftp.source

Class SftpSourceConfiguration

java.lang.Object

org.springframework.cloud.stream.app.sftp.source.SftpSourceConfiguration

@EnableBinding(value=org.springframework.cloud.stream.messaging.Source.class)
 @EnableConfigurationProperties(value={org.springframework.cloud.stream.app.sftp.common.source.SftpSourceProperties.class,FileConsumerProperties.class,TriggerPropertiesMaxMessagesDefaultUnlimited.class})
 @Import(value={TriggerConfiguration.class,org.springframework.cloud.stream.app.sftp.common.source.SftpSourceSessionFactoryConfiguration.class,SftpSourceIdempotentReceiverConfiguration.class,SftpSourceTaskLauncherConfiguration.class})
public class SftpSourceConfiguration
extends Object

Author:

Gary Russell, Artem Bilan, Chris Schaefer, Christian Tzolov, David Turanski

Constructor Summary

Constructors

Constructor and Description
SftpSourceConfiguration()

Method Summary

Modifier and Type	Method and Description
org.springframework.cloud.stream.app.sftp.common.source.ListFilesRotator	rotator(org.springframework.cloud.stream.app.sftp.common.source.SftpSourceProperties properties, org.springframework.beans.factory.ObjectProvider<org.springframework.cloud.stream.app.sftp.common.source.SftpSourceSessionFactoryConfiguration.DelegatingFactoryWrapper> factory)
org.springframework.messaging.MessageChannel	sftpFileListChannel()
org.springframework.messaging.MessageChannel	sftpFileTaskLaunchChannel()
org.springframework.integration.dsl.IntegrationFlow	sftpInboundFlow(org.springframework.integration.file.remote.session.SessionFactory<com.jcraft.jsch.ChannelSftp.LsEntry> sftpSessionFactory, FileConsumerProperties fileConsumerProperties)
org.springframework.integration.sftp.session.SftpRemoteFileTemplate	sftpTemplate(org.springframework.integration.file.remote.session.SessionFactory<com.jcraft.jsch.ChannelSftp.LsEntry> sftpSessionFactory, org.springframework.cloud.stream.app.sftp.common.source.SftpSourceSessionFactoryConfiguration.DelegatingFactoryWrapper wrapper, org.springframework.cloud.stream.app.sftp.common.source.SftpSourceProperties properties)
org.springframework.messaging.Message<?>	transformSftpMessage(org.springframework.messaging.Message<?> message)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SftpSourceConfiguration

public SftpSourceConfiguration()

Method Detail

sftpFileListChannel

@Bean
public org.springframework.messaging.MessageChannel sftpFileListChannel()

sftpFileTaskLaunchChannel

@Bean
public org.springframework.messaging.MessageChannel sftpFileTaskLaunchChannel()

sftpInboundFlow

@Bean
public org.springframework.integration.dsl.IntegrationFlow sftpInboundFlow(org.springframework.integration.file.remote.session.SessionFactory<com.jcraft.jsch.ChannelSftp.LsEntry> sftpSessionFactory,
                                                                                 FileConsumerProperties fileConsumerProperties)

sftpTemplate

@Bean
 @ConditionalOnProperty(name="sftp.stream")
public org.springframework.integration.sftp.session.SftpRemoteFileTemplate sftpTemplate(org.springframework.integration.file.remote.session.SessionFactory<com.jcraft.jsch.ChannelSftp.LsEntry> sftpSessionFactory,
                                                                                                                                          @Autowired(required=false)
                                                                                                                                          org.springframework.cloud.stream.app.sftp.common.source.SftpSourceSessionFactoryConfiguration.DelegatingFactoryWrapper wrapper,
                                                                                                                                          org.springframework.cloud.stream.app.sftp.common.source.SftpSourceProperties properties)

transformSftpMessage

@ConditionalOnProperty(name="sftp.listOnly")
 @IdempotentReceiver(value="idempotentReceiverInterceptor")
 @ServiceActivator(inputChannel="sftpFileListChannel",
                  outputChannel="output")
public org.springframework.messaging.Message<?> transformSftpMessage(org.springframework.messaging.Message<?> message)

rotator

@Bean
public org.springframework.cloud.stream.app.sftp.common.source.ListFilesRotator rotator(org.springframework.cloud.stream.app.sftp.common.source.SftpSourceProperties properties,
                                                                                              org.springframework.beans.factory.ObjectProvider<org.springframework.cloud.stream.app.sftp.common.source.SftpSourceSessionFactoryConfiguration.DelegatingFactoryWrapper> factory)