spring-integration - Spring 集成 Java DSL : creating jms Message Driver Channel Adapter

Question

我在使用以下消息驱动程序 channel 适配器时遇到问题

@Bean
    public IntegrationFlow jmsInboundFlow() {
        return IntegrationFlows.from(Jms.messageDriverChannelAdapter(this.jmsConnectionFactory)
                .outputChannel(MessageChannels.queue("inbound").get())
                .destination("test"))   
                .get();
    }

    @Bean
    public IntegrationFlow channelFlow() {
        return IntegrationFlows.from("inbound")
                .transform("hello "::concat)
                .handle(System.out::println)
                .get();
    }

我收到有关“调度程序没有 channel 订阅者”的错误消息。将消息有效负载发送到另一个集成流的首选配置是什么？

Answer 1

使用该 Java DSL channel auto-creation你应该小心。例如.outputChannel(MessageChannels.queue("inbound").get())不填充 MessageChannel bean 到 bean 工厂。但从另一边IntegrationFlows.from("inbound")这样做。

要解决您的问题，我建议提取 @Bean为您 inbound channel ，或仅依靠 DSL:

return IntegrationFlows.from(Jms.messageDriverChannelAdapter(this.jmsConnectionFactory)
            .destination("test"))
            .channel(MessageChannels.queue("inbound").get())   
            .get();

请随意提出 GH 问题以修复该 .outputChannel() 上的 JavaDocs或将其全部删除，因为它很困惑。