Spring Integration FTP - InboundChannelAdapter停止使用新的FTP服务器

@Configuration
@EnableIntegration
public class FtpIntegrationConfig {

    @Bean
    public DefaultFtpSessionFactory ftpSessionFactory() {
        DefaultFtpSessionFactory factory = new DefaultFtpSessionFactory();
        factory.setHost("ftp.example.com");
        factory.setPort(21);
        factory.setUsername("username");
        factory.setPassword("password");
        return factory;
    }

    @Bean
    public FtpInboundFileSynchronizer ftpInboundFileSynchronizer(DefaultFtpSessionFactory ftpSessionFactory) {
        FtpInboundFileSynchronizer synchronizer = new FtpInboundFileSynchronizer(ftpSessionFactory);
        synchronizer.setRemoteDirectory("/path/to/remote/directory");
        synchronizer.setFilter(new AcceptOnceFileListFilter<>());
        return synchronizer;
    }

    @Bean
    public FtpInboundFileSynchronizingMessageSource ftpInboundMessageSource(FtpInboundFileSynchronizer ftpInboundFileSynchronizer) {
        FtpInboundFileSynchronizingMessageSource messageSource = new FtpInboundFileSynchronizingMessageSource(ftpInboundFileSynchronizer);
        messageSource.setLocalDirectory(new File("/path/to/local/directory"));
        messageSource.setAutoCreateLocalDirectory(true);
        return messageSource;
    }

    @Bean
    public IntegrationFlow ftpInboundFlow(FtpInboundFileSynchronizingMessageSource ftpInboundMessageSource) {
        return IntegrationFlows.from(ftpInboundMessageSource, poller -> poller.poller(spec -> spec.fixedDelay(5000)))
                .handle(System.out::println)
                .get();
    }

    @Bean
    public ApplicationRunner runner(FtpInboundFileSynchronizingMessageSource ftpInboundMessageSource) {
        return args -> {
            // 启动InboundChannelAdapter
            ftpInboundMessageSource.start();

            // 停止使用新的FTP服务器
            ftpInboundMessageSource.stop();
        };
    }
}