【发布时间】:2018-05-27 13:56:33
【问题描述】:
我正在使用 Spring 与 weblogic jms 的集成。我的逻辑是将 json 对象放入 jms 队列中,并将其从队列中消耗到通道中,对其进行验证并根据特定字段对其进行路由。如果有任何错误,请进行修复并将其放回队列中。我有两个问题。 1.当消息被消费到对象中时,我仍然可以在weblogic的管理控制台中看到该对象处于挂起状态。 2.修复验证后,如果将修改后的对象放入队列中,我会从队列中获取原始对象。
<int-jms:outbound-channel-adapter id="jmsOutbound"
channel="requestChannel" connection-factory="queueConnectionFactory"
destination="inputQueue" />
<int-jms:message-driven-channel-adapter
id="jmsInbound" connection-factory="queueConnectionFactory"
destination="inputQueue" channel="routingChannel" />
if (message.getHeaders().get("documentType").equals("sec"))
routingChannels.add(outboundSecChannel);
else if (message.getHeaders().get("documentType").equals("unds"))
routingChannels.add(outboundFChannel);
else if (message.getHeaders().get("documentType").equals("CH"))
routingChannels.add(outboundAChannel);
else{
routingChannels.add(errorChannel);
}
使用路由加入频道
感谢您的帮助。
【问题讨论】:
标签: jms spring-integration weblogic12c