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?

Gary Russell Gary Russell · Accepted Answer · 2017-02-19T14:56:07

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]

Spring Integration ftp inbound channel adapter recursive synchronization

1 Answers