Spring集成FTP出站网关控制台输出

Question

在带有Java配置的ftp出站网关的Spring集成文档示例（16.8.1）中，如何将应答通道的有效负载记录到控制台？

Answer 1

添加一个WireTap@Bean并将其MessageChannel连接到LoggingHandler。

将有线抽头添加为网关输出通道的通道拦截器。

或者，使用< code >。wiretap()当使用Java DSL时。

这里是文档。

编辑

Java Config：

@SpringBootApplication
public class So49308064Application {

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

    @Bean
    public ApplicationRunner runner (Gate gate) {
        return args -> {
            List<String> list = gate.list("foo");
            System.out.println("Result:" + list);
        };
    }

    @ServiceActivator(inputChannel = "ftpLS")
    @Bean
    public FtpOutboundGateway getGW() {
        FtpOutboundGateway gateway = new FtpOutboundGateway(sf(), "ls", "payload");
        gateway.setOption(Option.NAME_ONLY);
        gateway.setOutputChannelName("results");
        return gateway;
    }

    @Bean
    public MessageChannel results() {
        DirectChannel channel = new DirectChannel();
        channel.addInterceptor(tap());
        return channel;
    }

    @Bean
    public WireTap tap() {
        return new WireTap("logging");
    }

    @ServiceActivator(inputChannel = "logging")
    @Bean
    public LoggingHandler logger() {
        LoggingHandler logger = new LoggingHandler(Level.INFO);
        logger.setLogExpressionString("'Files:' + payload");
        return logger;
    }

    @Bean
    public DefaultFtpSessionFactory sf() {
        DefaultFtpSessionFactory sf = new DefaultFtpSessionFactory();
        sf.setHost("...");
        sf.setUsername("...");
        sf.setPassword("...");
        return sf;
    }

    @MessagingGateway(defaultRequestChannel = "ftpLS", defaultReplyChannel = "results")
    public interface Gate {

        List<String> list(String directory);

    }

}

.

2018-03-29 09:04:20.383  INFO 15158 --- [           main] o.s.integration.handler.LoggingHandler   
             : Files:bar.tx,bar.txt,baz.txt
Result:[bar.tx, bar.txt, baz.txt]

JavaDSL：

@SpringBootApplication
public class So49308064Application {

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

    @Bean
    public ApplicationRunner runner (Gate gate) {
        return args -> {
            List<String> list = gate.list("foo");
            System.out.println("Result:" + list);
        };
    }

    @Bean
    public IntegrationFlow flow() {
        return f -> f
                .handle((Ftp.outboundGateway(sf(), "ls", "payload").options(Option.NAME_ONLY)))
                .log(Level.INFO, "lsResult", "payload")
                .bridge(); // needed, otherwise log ends the flow.
    }

    @Bean
    public DefaultFtpSessionFactory sf() {
        DefaultFtpSessionFactory sf = new DefaultFtpSessionFactory();
        sf.setHost("...");
        sf.setUsername("...");
        sf.setPassword("...");
        return sf;
    }

    @MessagingGateway(defaultRequestChannel = "flow.input")
    public interface Gate {

        List<String> list(String directory);

    }

}

.

2018-03-29 09:12:28.991  INFO 16638 --- [           main] lsResult                                 
                 : [bar.tx, bar.txt, baz.txt]
Result:[bar.tx, bar.txt, baz.txt]