如何在单独的 spring 集成应用程序中实现 JMS Inbound & Outbound 配置？

Question

我的用例是我们项目中的通知服务实现。

我们已经将 spring 与 jms 一起使用，并且它在休息服务中运行良好。能够使用 JMSTemplate 的 convertAndSend()、convertAndReceive() 函数从一个应用程序向队列发送消息并从另一个应用程序的队列接收消息。

现在我想使用 spring 集成的 java dsl 方法来做到这一点。我们通过在 ActiveMQ 的单个应用程序中使用 Jms 的 inboundGateway() 和 outboundGateway() 做了一个示例。

如何在不同的应用程序中使用spring集成的java dsl只发送/接收消息？

这是我的代码，

@Bean
public IntegrationFlow jmsInboundFlow() {
    return IntegrationFlows
            .from(Jms.inboundGateway(this.connectionFactory)
                    .destination("pan.outbound"))
            .transform((String s) -> s.toUpperCase())
            .channel("in-bound-request-channel")
            .get();
}

@Bean
public IntegrationFlow jmsOutboundGatewayFlow() {
    return IntegrationFlows.from("out-bound-request-channel")
            .handle(Jms.outboundGateway(this.connectionFactory)
                        .requestDestination("pan.outbound"))
            .log()
            .bridge()
            .get();
}

@MessagingGateway
interface EchoGateway {

    @Gateway(requestChannel = "out-bound-request-channel")
    String send(String message);

}

Answer 1

您只需拆分配置 - JMS 入站适配器在一个应用程序中，而 JMS 出站适配器在第二个应用程序中。 方式与一个应用程序中的方式完全相同吗？ （也许我错过了一些信息？）