0
我正在构建在Camel和ActiveMQ上的数据管道上工作。一个路由从一个队列中取出的消息,并通过暴露的Netty它一个C插座上++组件采取它们:骆驼 - 自制“交易”?
<from uri="activemq:queue:inqueue?concurrentConsumers=1"/
<camel:loadBalance inheritErrorHandler="false">
<camel:roundRobin/>
<camel:to uri="netty:tcp://0.0.0.0:0?logicalName=comp#1&sync=false"/>
<camel:to uri="netty:tcp://0.0.0.0:0?logicalName=comp#2&sync=false"/>
</camel:loadBalance>
我想能够跟踪信息和跟踪的状态;如果其中一个C++组件没有以特定阈值成功响应,我想将该消息放回队列中。我想在队列和Netty之间加入一个Camel进程来跟踪这个。
这是一个可行的想法吗?这将如何处理?