Как настроить SFTP исходящий шлюз с помощью Java Config?

Question

Я хотел бы использовать SFTP Outbound Gateway для get файла через SFTP, но я нахожу только примеры с помощью XML-конфигурации. Как это можно сделать с помощью конфигурации Java?

Update (Спасибо Артему Билана помощь)

MyConfiguration класс:

@Configuration 
public class MyConfiguration { 

    @Bean 
    public SessionFactory<LsEntry> sftpSessionFactory() { 
     DefaultSftpSessionFactory sftpSessionFactory = new DefaultSftpSessionFactory(); 
     sftpSessionFactory.setHost("myhost"); 
     sftpSessionFactory.setPort(22); 
     sftpSessionFactory.setUser("uname"); 
     sftpSessionFactory.setPassword("pass"); 
     sftpSessionFactory.setAllowUnknownKeys(true); 
     return new CachingSessionFactory<LsEntry>(sftpSessionFactory); 
    } 

    @Bean 
    @ServiceActivator(inputChannel = "sftpChannel") 
    public MessageHandler handler() { 
     SftpOutboundGateway sftpOutboundGateway = new SftpOutboundGateway(sftpSessionFactory(), "get", "#getPayload() == '/home/samadmin/test.endf'"); 
     sftpOutboundGateway.setLocalDirectory(new File("C:/test/gateway/")); 
     return sftpOutboundGateway; 
    } 

} 

Мой класс приложения:

@SpringBootApplication 
@EnableIntegration 
public class TestIntegrationApplication { 

    public static void main(String[] args) { 
     SpringApplication.run(TestIntegrationApplication.class, args); 
    } 
} 

Конфигурация успешно сейчас, но не SFTP не происходит. Нужно выяснить, как запросить SFTP.

Answer 1

Цитирование Reference Manual:

@Bean 
@ServiceActivator(inputChannel = "sftpChannel") 
public MessageHandler handler() { 
    return new SftpOutboundGateway(ftpSessionFactory(), "ls"); 
} 

Также стоит обратить внимание на DSL образца Java в следующем разделе там.

EDIT

@Bean 
@ServiceActivator(inputChannel = "sftpChannel") 
public MessageHandler handler() { 
    SftpOutboundGateway sftpOutboundGateway = new SftpOutboundGateway(sftpSessionFactory(), "get", "payload"); 
    sftpOutboundGateway.setLocalDirectory(new File("C:/test/gateway/")); 
    return sftpOutboundGateway; 
} 

В случае GET SFTP команду expression CTOR ARG может быть как выше - просто ссылка на Message.getPayload() для всех входящих сообщений.

В этом случае вы должны отправить на sftpChannelMessage как:

new GenericMessage<>("/home/samadmin/test.endf"); 

Итак, что /home/samadmin/test.endf является payload этого Message. Когда он прибывает в SftpOutboundGateway, это выражение оценивается по этому сообщению, а getPayload() вызывается SpEL. Таким образом, команда GET будет предварительно сформирована с желаемым путем к удаленному файлу.

Другое сообщение может иметь совершенно другой путь к другому файлу.