来自原始jmsReplyTo的jms动态目标

Question

有一个请求队列，回复队列由客户端服务器实例创建，并固定到每个实例，而不是使用临时队列。

用例需要获取入站jms消息，然后将该消息发送到异步进程。一旦从服务接收到异步回复消息，我需要获取这些结果并回复原始消息的jmsReplyTo。Jms网关在这种情况下不起作用AFAIK

我正在使用jms消息驱动的通道适配器来处理带有一系列通道和服务激活器的消息，以处理进程外调用和异步回复。我正在尝试使用DynamicDestinationResolver无济于事。此外，我尝试以编程方式设置出站目标地址，但无法找到一个好方法来做到这一点。

这似乎是一种常见的模式，但我找不到一个完全断开连接的异步请求响应的好例子。断开连接意味着通常的异步jms请求-应答似乎不符合需要。

上下文配置：

<!-- Input from Amq -->

<amq:queue id="requestQueue" physicalName="${request.queue}" />

<int-jms:message-driven-channel-adapter id="jmsIn"
                                    connection-factory="jmsConnectionFactory"
                                    destination="requestQueue"
                                    channel="queueRequestChannel" concurrent-consumers="5" />

<int:channel id="queueRequestChannel" />

<int:service-activator input-channel="queueRequestChannel" ref="switchMessageHandler" method="processSwitchMessage"
        output-channel="cardNetworkOutChannel"/>

<!-- Output to Card Network-->
<int:channel id="cardNetworkOutChannel" />

<!--<int:service-activator input-channel="cardNetworkOutChannel" ref="cardNetworkHandler" method="send8583Message" />-->

<!-- Simply used to mock the card network by transforming a SwithMessage to a SwitchMessageResponse * Not needed for target solution -->
<int:transformer id="requestResponseTransformer" ref="nettyCardNetworkClientMock" input-channel="cardNetworkOutChannel"
                 method="process" output-channel="cardNetworkInChannel"/>

<!-- Input from Card Network -->
<int:channel id="cardNetworkInChannel" />

<int:service-activator input-channel="cardNetworkInChannel" ref="switchMessageHandler" method="sendSwitchMessage"
                       output-channel="queueReplyChannel"/>


<int:channel id="queueReplyChannel"/>

<int-jms:outbound-channel-adapter
        destination-resolver="simpleDestinationResolver" connection-factory="jmsConnectionFactory"
        channel="queueReplyChannel" destination-expression="headers.jms_replyTo" />

Answer 1

我刚刚更新了jms示例应用程序，使服务器端使用独立的适配器，而不是入站网关，它工作得很好。。。

<!--    <jms:inbound-gateway id="jmsin" -->
<!--                         request-destination="requestQueue" -->
<!--                         request-channel="demoChannel"/> -->

<channel id="demoChannel"/>

<jms:message-driven-channel-adapter destination="requestQueue" channel="demoChannel" />

<service-activator input-channel="demoChannel" ref="demoBean" output-channel="reply" />

<channel id="reply" />

<jms:outbound-channel-adapter channel="reply" destination-expression="headers['jms_replyTo']" />

打开调试日志-我们发布了很多有用的东西。

编辑

我只是通过…使其异步。。。

<channel id="reply">
    <queue/>
</channel>

<jms:outbound-channel-adapter channel="reply" destination-expression="headers['jms_replyTo']">
    <poller fixed-delay="3000"/>
</jms:outbound-channel-adapter>

编辑2

根据您在客户端上使用的内容，许多客户端要求将入站消息id用作相关id。（默认情况下，对于具有命名回复队列的出站网关，这是正确的，除非您提供相关密钥）。

因此，要设置correlationId，您可以使用标头充实器；我刚刚测试过这个。。。

<chain input-channel="reply">
    <header-enricher>
        <header name="jms_correlationId" expression="headers['jms_messageId']" />
    </header-enricher>
    <jms:outbound-channel-adapter destination-expression="headers['jms_replyTo']"/>
    <poller fixed-delay="1000" />
</chain>

如果客户端本身正在设置相关id标头，则这不是问题。