用rabbitmq在maxAttempts之後使用spring-cloud-stream更新應用程序狀態

Question

我正在使用spring-cloud-stream在服務之間進行通信。我使用3個maxAttempts配置了RepublishMessageRecoverer，並且還使用autoBindDlq和republishToDlq配置了使用者輸入綁定。

重新發布工作正常。我只想檢測到所有嘗試都已嘗試並更新應用程序狀態，以便反映錯誤狀態。如果我能得到櫃檯也能解決我的問題。

謝謝！

Answer 1

內部重試上下文（包含傳遞計數）不會公開給應用程序。

我們正在研究一種新的錯誤處理策略，該策略將允許您訂閱錯誤渠道以及重新發布恢復程序，以便您能夠以此方式獲得通知。

我對當前的活頁夾沒有很好的解決方案。

我想你可以做一些2階段的DLQ。

添加第二個StreamListener，從主偵聽器的DLQ中消耗，並將入站消息發送到最終的DLQ。

如果消息流經第二個偵聽器，則表示主偵聽器出現故障。

雖然這有點複雜。