动态jms出站网关

Question

request -> appA -> activemq -> appB -> activemq -> appA -> response

<bean id="jmsSecureConnectionFactory" class="org.apache.activemq.spring.ActiveMQConnectionFactory">
    <property name="brokerURL" value="${brokerUrl}" />
</bean>

<bean id="jmsPooledConnectionFactory" class="org.apache.activemq.jms.pool.PooledConnectionFactory">
    <property name="connectionFactory" ref="jmsSecureConnectionFactory" />
    <property name="createConnectionOnStartup" value="false" />
    <property name="maxConnections" value="1" />
    <property name="maximumActiveSessionPerConnection" value="1" />
    <property name="idleTimeout" value="10" />
</bean>

<int:channel id="clientGatewayChannel" />

<int:gateway id="jmsMessageServiceGateway"
    service-interface="com.abc.JmsMessageServiceGateway"
    default-request-channel="clientGatewayChannel" />

<int-jms:outbound-gateway request-channel="clientGatewayChannel"
    request-destination-expression="'REQUEST.' + payload.processor"
    reply-destination-expression="'RESPONSE.' + payload.processor"
    extract-request-payload="true" connection-factory="jmsPooledConnectionFactory" />

<bean id="jmsChannelResolver" class="com.abc.JmsChannelResolver" />

<int:channel id="dynamicRouter" />

<int:router input-channel="dynamicRouter"
    expression="@jmsChannelResolver.resolve(payload.processor)" />

我可以看到请求消息被加入和出列，响应消息被加入和出列。但我有个例外，

org.springframework.integration.support.channel.ChannelResolutionException: no output-channel or replyChannel header available

我应该如何检索响应？

Answer 1

该错误意味着发送到DynamicRouter的任何内容都不是来自设置ReplyChannel标头的组件（示例包括gateway、入站网关和MessagingTemplate.SendandReceive()方法）。

或者，在消息到达DynamicRouter之前，某些东西已经删除了该标头。

只要上游的流量是正确的，你所拥有的应该能很好地工作。