Spring 集成 DSL - CharacterStreamWritingMessageHandler

Question

我正在为 DSL 中的 basic-amqp 示例 (https://github.com/spring-projects/spring-integration-samples/blob/master/basic/amqp/src/main/resources/META-INF/spring/integration/spring-integration-context.xml) 编写示例代码

@Bean
public IntegrationFlow receiveGreetingFromGreetingQueueToConsole(ConnectionFactory connectionFactory) {

    return IntegrationFlows.from(Amqp.inboundAdapter(connectionFactory, "greeting.queue"))
            .log()
            .<String,String>transform(m -> "Received " + m)
            .handle(CharacterStreamWritingMessageHandler.stdout())
            .get();

}

如何在

上应用 setShouldAppendNewLine 布尔值

.handle(CharacterStreamWritingMessageHandler.stdout())

我不想仅仅为了设置这个属性而将处理程序声明为 bean。希望标准输出为此接受一个参数。

Answer 1

不一定是豆子……

@Bean
public IntegrationFlow receiveGreetingFromGreetingQueueToConsole(ConnectionFactory connectionFactory) {

    CharacterStreamWritingMessageHandler stdout = CharacterStreamWritingMessageHandler.stdout();
    stdout.setShouldAppendNewLine(true);
    return IntegrationFlows.from(Amqp.inboundAdapter(connectionFactory, "greeting.queue"))
            .log()
            .<String,String>transform(m -> "Received " + m)
            .handle(stdout)
            .get();

}

但是，我同意 DSL 使用流畅的 API 会很好；请在 GitHub 上打开一个问题。