@EnableBinding(value=org.springframework.cloud.stream.messaging.Source.class) @EnableConfigurationProperties(value={org.springframework.cloud.stream.app.sftp.common.source.SftpSourceProperties.class,TriggerPropertiesMaxMessagesDefaultUnlimited.class,SftpMultiSourceTaskNameProperties.class}) @Import(value={TriggerConfiguration.class,org.springframework.cloud.stream.app.sftp.common.source.SftpSourceSessionFactoryConfiguration.class,SftpDataflowSourceIdempotentReceiverConfiguration.class}) public class SftpDataflowSourceConfiguration extends Object
Modifier and Type | Class and Description |
---|---|
static class |
SftpDataflowSourceConfiguration.MultiSourceTaskNamesCondition
Condition required to configure the SftpMultiSourceTaskNameMapper.
|
Constructor and Description |
---|
SftpDataflowSourceConfiguration() |
Modifier and Type | Method and Description |
---|---|
org.springframework.integration.dsl.IntegrationFlow |
sftpDataFlowInboundFlow(org.springframework.integration.file.remote.session.SessionFactory<com.jcraft.jsch.ChannelSftp.LsEntry> sftpSessionFactory) |
org.springframework.messaging.MessageChannel |
sftpListInputChannel() |
SftpMultiSourceTaskNameMapper |
sftpMultiSourceTaskNameMapper(SftpMultiSourceTaskNameProperties taskNameProperties) |
org.springframework.messaging.MessageChannel |
taskLaunchRequestChannel() |
org.springframework.cloud.stream.app.tasklaunchrequest.support.CommandLineArgumentsMessageMapper |
taskLaunchRequestContextProvider(org.springframework.cloud.stream.app.sftp.common.source.SftpSourceProperties sourceProperties) |
org.springframework.messaging.Message<?> |
transformSftpMessage(org.springframework.messaging.Message<?> message) |
org.springframework.messaging.Message<?> |
transformToTaskLaunchRequestIfNecessary(org.springframework.messaging.Message<?> message) |
org.springframework.integration.sftp.session.SftpRemoteFileTemplate |
wrappedSftpTemplate(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) |
@Bean public org.springframework.messaging.MessageChannel sftpListInputChannel()
@Bean public org.springframework.messaging.MessageChannel taskLaunchRequestChannel()
@Bean public org.springframework.cloud.stream.app.tasklaunchrequest.support.CommandLineArgumentsMessageMapper taskLaunchRequestContextProvider(org.springframework.cloud.stream.app.sftp.common.source.SftpSourceProperties sourceProperties)
@Bean @Conditional(value=SftpDataflowSourceConfiguration.MultiSourceTaskNamesCondition.class) public SftpMultiSourceTaskNameMapper sftpMultiSourceTaskNameMapper(SftpMultiSourceTaskNameProperties taskNameProperties)
@Bean public org.springframework.integration.dsl.IntegrationFlow sftpDataFlowInboundFlow(org.springframework.integration.file.remote.session.SessionFactory<com.jcraft.jsch.ChannelSftp.LsEntry> sftpSessionFactory)
@Bean public org.springframework.integration.sftp.session.SftpRemoteFileTemplate wrappedSftpTemplate(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)
@IdempotentReceiver(value="idempotentReceiverInterceptor") @ServiceActivator(inputChannel="sftpListInputChannel", outputChannel="taskLaunchRequestChannel") public org.springframework.messaging.Message<?> transformSftpMessage(org.springframework.messaging.Message<?> message)
@ServiceActivator(inputChannel="taskLaunchRequestChannel", outputChannel="output") public org.springframework.messaging.Message<?> transformToTaskLaunchRequestIfNecessary(org.springframework.messaging.Message<?> message)
Copyright © 2020 Pivotal Software, Inc.. All rights reserved.