@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
Constructor and Description |
---|
SftpSourceConfiguration() |
Modifier and Type | Method and Description |
---|---|
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) |
@Bean public org.springframework.messaging.MessageChannel sftpFileListChannel()
@Bean public org.springframework.messaging.MessageChannel sftpFileTaskLaunchChannel()
@Bean public org.springframework.integration.dsl.IntegrationFlow sftpInboundFlow(org.springframework.integration.file.remote.session.SessionFactory<com.jcraft.jsch.ChannelSftp.LsEntry> sftpSessionFactory, FileConsumerProperties fileConsumerProperties)
@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)
@ConditionalOnProperty(name="sftp.listOnly") @IdempotentReceiver(value="idempotentReceiverInterceptor") @ServiceActivator(inputChannel="sftpFileListChannel", outputChannel="output") public org.springframework.messaging.Message<?> transformSftpMessage(org.springframework.messaging.Message<?> message)
Copyright © 2020 Pivotal Software, Inc.. All rights reserved.