Spring Integration DSL JMS 请求/回复流

Question

我正在尝试使用这样描述的 Spring Integration Java DSL 创建请求/回复流：

IntegrationFlows.from(directChannel)
                .handle(Jms.outboundGateway(connectionFactory)
                        .requestDestination(requestDestination)
                        .replyDestination(replyDestination))
                .handle(replyHandler)
                .get();

如果我终止了应该处理回复的应用程序，那么回复会留在队列中，并且不会在应用程序下次启动时被使用。当我使用此流程发送后续请求时，收到的是上一条消息，而不是最新的回复。

我正在测试的消息流看起来像

App A 发送消息 -> 停止 A -> App B 接收消息并发送回复 R1

A 启动 -> A 发送另一个消息 -> B 接收消息并发送 回复 R2 -> A 收到 R1

R2 留在队列中

我做错了吗？

谢谢！

Answer 1

这种情况根本不应该发生，我希望 R1 永远留在队列中，因为网关使用消息选择器来接收基于出站消息 ID 的回复。所以新实例不应该选择旧消息。

在这种模式下，它希望接收应用程序将入站消息 id 复制到 JMSCorrelationID 标头。当入站消息没有JMSCorrelationID 时，这是一种常见的 JMS 模式。

尝试将correlationKey 设置为JMSCorrelationID。在这种模式下，请求网关对每个实例使用唯一的 id，并且它希望接收方简单地回显入站 JMSCorrelationID 标头。

如果你能得到双方的调试日志，它可能有助于追踪它。