dead-letter

0熱度

2回答

如何從死信隊列中讀取消息並將其放回交易範圍內的父隊列中，因爲只有一個頂級實體能夠參與交易？通常情況下，我會使用傳輸隊列將消息從一個隊列移動到另一個隊列作爲原子操作，但我不相信DLQ有傳輸隊列，即使他們這樣做，我也不會遇到處理傳輸的問題排隊DLQ！我需要以安全的方式執行此重新提交，並且不會在重新提交過程中丟失消息。

0熱度

1回答

Akka集羣 - 來自死信的消息？

我正在使用Akka集羣，我有一個有趣的問題。我在節點A上有一個演員Actor1（akka.tcp：//[email protected]：2554）。此演員發現使用 val actor2sel = context.actorSelection(RootActorPath(m.address)/"user"/"actor2") m哪裏是集羣的成員的另一節點上的另一行動者。 actor2sel是

0熱度

1回答

確切的異常信息爲什麼這些消息是死信

我有一個應用程序將消息發送到azure服務總線隊列。我還有另一個應用程序，它從這個隊列中讀取消息，然後進程將處理後的消息發送給主題。我看到我的大部分消息正在轉向dlq。當我在azure服務總線資源管理器中看到異常時，我發現它會爲所有消息引發相同的異常 - 超過最大重試次數..我想知道實際的異常，因爲消息移動到了dlq。我在哪裏可以找到這個例外細節？我相信這個異常細節可能會被存儲在任何地方？

1熱度

1回答

重新提交已過期的死信回隊列

我有大量的消息在azure服務總線死信隊列中。當我看到這些消息時，我看到大部分消息都已過期。我想知道當我們嘗試將過期的deadletter隊列消息重新提交回其原始隊列時會發生什麼？任何人都可以幫我解釋這一點嗎？謝謝！

1熱度

1回答

如何避免郵件在死信隊列中登陸？

如何設計應用程序，使消息儘可能避免死信隊列。按照下文維基百科文檔是一個消息被髮送到其被髮送到不存在的隊列中的dead letter queue 消息的原因。超出隊列長度限制。已超過消息長度限制。消息是由另一隊列交換拒絕。消息達到一閾值讀計數器號碼，因爲它不被消耗。有時候這被稱爲「退出隊列」。我們將能夠設計系統避免了由於衆所周知的原因。但是如何讓系統解決未知的情況。我不是在尋找任何供應商

0熱度

1回答

使用一致的哈希交換綁定的過期隊列上的死信刻錄消息

我遇到了處理與特定源相關的事件的情況。每個源都有一個密鑰或ID，我可以用它作爲散列。來自每個來源的事件必須按順序處理，但是來自不同來源的事件可以並行化，以實現水平可伸縮性。將有數百個源密鑰。我打算在將消息提交給RabbitMQ時將密鑰設置爲路由密鑰的一部分，然後使用consistent-hash-exchange，以便將來自同一源的事件路由到同一隊列。當時我正在考慮使用TTL動態綁定來自消費者的

1熱度

2回答

Webshpere MQ基於提取計數器將消息重定向到DLQ

當IBM WebSphere MQ中的消息從計數器大於3時，是否有可能將消息從隊列重定向到死信隊列（DLQ）？

1熱度

1回答

使用Akka創建消息環的死信

我想創建一個使用遠程actor的示例Akka應用程序。目標是創建例如16個以順序方式交換消息的演員（演員16與演員15,15到14等會談，並且1與演員16會談）。但是，我在通信方面遇到了問題，因爲我連續出現此錯誤。 [INFO] [2017年5月4日15：45：58.248] [ActorFlasks-akka.actor.default-調度-4] [阿卡：// ActorFlasks/dead

1熱度

1回答

如何在Apache Camel中的重新獲取耗盡後調用Web服務？

我並沒有發現能促進這個問題的解決方案的企業集成模式或配方：重新傳送嘗試後已經用盡，我需要發送Web服務請求回到始發源，以通知發送失敗的發件人。在耗盡所有重新發送嘗試後，我應該將消息移至死信隊列嗎？然後創建一個新的使用者在該DL隊列上偵聽？我的每個源消息隊列都需要一個獨特的死信隊列嗎？在我將它移動到死信隊列之前，我應該添加一個消息頭，注意源隊列嗎？如果所有消息都發送到單個死信隊列，那麼我的消費者

2熱度

2回答

我們如何分析Activemq的死信隊列中的消息

然後，代理將消息發送到死信隊列，以便稍後進行分析。這些是來自apache activemq文章的引用。我的策略也是一樣的。我想稍後分析死信隊列中的消息。我怎樣才能做到這一點？