dead-letter

0熱度

1回答

我有分銷商/工人模型。機A - 分銷商機器B - 工人當工人B的嘗試將消息發送到分銷商在錯誤的Q名，它把消息到事務死信Q. 我在等待郵件發送到錯誤q。

0熱度

1回答

我一直在關注發送消息到死信通道的例子，但還沒有計算出如何測試這個。消息確實被路由到DLC，但我想確保這是經過測試的。例如，我將如何測試在日誌：dead端點上收到的消息。此代碼是從CamelTestSupport延伸的測試類： @Override protected RouteBuilder createRouteBuilder() throws Exception { return

1熱度

3回答

的RabbitMQ - 他們到達過期時間之後路由消息

我最近發現RabbitMQ的功能，可以讓您延遲的消息，雖然我找不到類似的任何例子它的偉大工程，我需要什麼：讓我們說有3種類型的消息：A，B和C.我們已經有了2個delay_queues爲1小時至2小時'x-message-ttl值。還有3種類型的destination_queue - 每種用於特定的消息類型。我想什麼來實現在delay_queues的一個消息到達後的TTL它會被路由到根據其類型

1熱度

1回答

消息去死信而不是發件人（akka路由器）[斯卡拉]

其實我很難讓我的演員（路由器）系統正常工作。我的設置：我試圖在播放控制器中使用akka路由器。對於依賴注入我使用scaldi。 scaldi模塊： class UserDAOModule extends Module { binding to new ExampleRouter binding toProvider new UserDAOWorker } 阿卡路由器：

0熱度

1回答

使用javaDSL從camel路由消息中獲取頭文件

我需要將死信重定向到消息頭中定義的目錄。我嘗試這樣做： errorHandler(deadLetterChannel("direct:dead")); from("direct:dead") .setHeader("CamelFileName", simple( new SimpleDateFormat("yyyyMMdd_HHmmss").format(Calenda

0熱度

2回答

爲什麼不能用scaldi綁定到單個actor實例（akka路由器）？

我目前正忙於使用scaldi實現我的Akka路由器邏輯進行依賴注入。爲什麼我不能用scaldi綁定到一個單獨的actor實例，因爲我的actor是一個路由器，我只想要它的一個實例？我來問這個問題的方式是another stackoverflow entry。我scaldi模塊： class DAOModule extends Module { bind toProvider new

1熱度

1回答

nservicebus：事件和死信隊列

在NSB中使用Pub/Sub模型時，以下兩種情況看起來會導致死信隊列填滿，最終導致「資源不足」錯誤。 1）發佈不具有用戶 2）用戶離線對於我們的目的，我們不感興趣的歷史事件當用戶啓動，所以輸入隊列被清除在啓動事件類型。然而，當用戶離線時發佈的事件填滿了死信隊列。我誤解了命令與事件嗎？這是我期望從命令行爲，但預期事件消失，如果不訂閱。

2熱度

1回答

如何使用特定ServiceInsight重新發送來自死信隊列的消息？

我們正在實施ServiceInsight作爲我們的Azure ServiceBus監控系統。我知道可以從錯誤隊列中重新發送消息，但可以重新發送死信隊列中的消息嗎？

2熱度

1回答

查看Azure服務總線死信的申請

我一直在環顧Web和GitHub，爲Azure服務總線提供現成的死信查看器。這是爲了讓我們的DevOps團隊能夠監控，查看和報告每次訂閱的死信，以便爲我們的公交車上的每個主題定製。我認爲這將是向DevOps交付的常見應用程序，因此相信那裏已經存在一個。所以在我開始扮演我自己的Windows窗體應用程序之前，是否有一個現有的查看器可能會錯過？

2熱度

2回答

死信字母消息沒有在RabbitMQ和節點上使用AMQP.Node

我想在我的工作人員中經過一定時間後收到消息。在發現所謂的死信交換後，我決定和Node和RabbitMQ一起去。該消息似乎發送到DeadExchange中的隊列，但消費者在WorkExchange中的WorkQueue中經過的時間之後從未接收到消息。 bindQueue關閉了，或者死信不起作用？我試過很多現在有不同的值。有人能指出我錯過了什麼嗎？ var amqp = require('amqp