【发布时间】:2016-10-29 19:59:23
【问题描述】:
我正在尝试使用蓝图创建骆驼路由,该蓝图在 activeMQ 队列上发送消息,然后侦听在请求中创建的临时队列上的响应。这似乎很基本,但我找不到使用它的示例。
我已尝试搜索和阅读文档,以下是我发现的内容: http://camel.apache.org/jms.html http://camel.apache.org/exchange-pattern.html http://camel.apache.org/request-reply.html https://access.redhat.com/documentation/en-US/Red_Hat_JBoss_Fuse/6.0/html/EIP_Transaction_Guide/files/FMRTxnJMSSynchronous.html http://kosalads.blogspot.com/2014/04/ApacheCamelRequestReplyPatternWithJavaDS.html http://grokbase.com/t/camel/users/128n88xeva/how-to-use-request-reply-in-jms http://camel.465427.n5.nabble.com/ExchangePattern-InOut-I-Can-t-get-any-response-td5056301.html https://examples.javacodegeeks.com/enterprise-java/apache-camel/apache-camel-exchange-example/
这令人沮丧。
我的 activeMQ 组件设置如下:
<to pattern="InOut" uri="activemq:queue:tripRequest.updateStatus.v1.0?useMessageIDAsCorrelationID=true"/>
<log message="Update Status responded ${out.body}"/>
日志显示了输入的 XML,这让我很惊讶。检查文档后,我创建了一个新的 activeMQ 实例,它侦听同一个队列并转储到日志,但这会引发错误,并且它会不断混淆我的日志和解组其他路由上的对象。
我怎样才能做到这一点?
【问题讨论】:
-
你是什么意思听响应?您的意思是正确的请求/回复,以便 activemq 创建一个临时响应队列吗?或者你的意思是异步请求/回复?此外,从您的问题中很难看出出了什么问题。如果您分享您的路线以及您的期望和实际看到的情况,那就更好了。
-
@SoucianceEqdamRashti 我分享了路线中我认为对这个问题有用的唯一部分。问题是我不知道如何构建下一个部分。我的路线只是以一个 activeMQ 调用结束。我想使用一个临时响应队列来处理回复。我会更新问题。
标签: java apache-camel activemq