2015-05-29 97 views
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&amp;sync=false"/> 
    <camel:to uri="netty:tcp://0.0.0.0:0?logicalName=comp#2&amp;sync=false"/> 
</camel:loadBalance> 

我想能够跟踪信息和跟踪的状态;如果其中一个C++组件没有以特定阈值成功响应,我想将该消息放回队列中。我想在队列和Netty之间加入一个Camel进程来跟踪这个。

这是一个可行的想法吗?这将如何处理?

回答

0

我对netty不太了解,但是你要找的东西听起来像错误处理。

您可以将以下内容添加到您的配置方法中进行试用。 如果您愿意,您还可以添加重试和任何其他形式的日志记录或错误管理。

errorHandler(deadLetterChannel("activemq:queue:errorQueue")); 

参考 http://camel.apache.org/error-handler.html