Spring Integration ftp inbound channel adapter recursive synchronization

Question

With Spring Integration, is it possible to synchronize files (including subfolder's files) recursively using ftp inbound channel adapter?

Answer 1

No; but you can fetch a complete remote directory tree with recursive MGET with the outbound gateway...

@SpringBootApplication
@IntegrationComponentScan
public class So42324318Application {

    public static void main(String[] args) {
        ConfigurableApplicationContext context = SpringApplication.run(So42324318Application.class, args);
        List<File> files = context.getBean(Gateway.class).fetchFiles("foo/*");
        System.out.println(files);
        context.close();
    }

    @MessagingGateway(defaultRequestChannel = "fetchRecursive")
    public interface Gateway {

        public List<File> fetchFiles(String remoteDir);

    }

    @Bean
    @ServiceActivator(inputChannel = "fetchRecursive")
    public FtpOutboundGateway gateway() {
        // Create a recursive MGET gateway that gets the remote directory from the payload
        FtpOutboundGateway gateway = new FtpOutboundGateway(sessionFactory(), "mget", "payload");
        gateway.setOptions("-R"); 
        gateway.setLocalDirectoryExpression(new SpelExpressionParser().parseExpression("#remoteDirectory"));
        return gateway;
    }

    @Bean
    public SessionFactory<FTPFile> sessionFactory() {
        return new CachingSessionFactory<>(ftpSF());
    }

    private SessionFactory<FTPFile> ftpSF() {
        DefaultFtpSessionFactory sf = new DefaultFtpSessionFactory();
        sf.setHost("10.0.0.3");
        sf.setUsername("ftptest");
        sf.setPassword("ftptest");
        sf.setClientMode(FTPClient.PASSIVE_LOCAL_DATA_CONNECTION_MODE);
        return sf;
    }

}

Result:

2017-02-19 09:55:09.351  INFO 61921 --- [           main] o.s.integration.ftp.session.FtpSession   : File has been successfully transferred from: foo/bar.tx
2017-02-19 09:55:09.353  INFO 61921 --- [           main] o.s.integration.ftp.session.FtpSession   : File has been successfully transferred from: foo/bar.txt
2017-02-19 09:55:09.356  INFO 61921 --- [           main] o.s.integration.ftp.session.FtpSession   : File has been successfully transferred from: foo/bar/abc.txt
2017-02-19 09:55:09.358  INFO 61921 --- [           main] o.s.integration.ftp.session.FtpSession   : File has been successfully transferred from: foo/baz.txt
2017-02-19 09:55:09.362  INFO 61921 --- [           main] o.s.integration.ftp.session.FtpSession   : File has been successfully transferred from: foo/foo/bar/qux.txt
2017-02-19 09:55:09.364  INFO 61921 --- [           main] o.s.integration.ftp.session.FtpSession   : File has been successfully transferred from: foo/foo/baz/fiz.txt
[foo/bar.tx, foo/bar.txt, foo/bar/abc.txt, foo/baz.txt, foo/foo/bar/qux.txt, foo/foo/baz/fiz.txt]