Spring集成Java DSL：创建jms消息驱动通道适配器

Question

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

@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();
    }

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

Answer 1

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

为了解决您的问题，我建议为您的inbound 频道提取@Bean，或者仅依靠DSL：

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

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