2015-05-29 127 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