CAP默認有失敗重試機制,達到50次后就不再重試;
那么對於這種仍然失敗的數據我們該怎么處理呢? 工作中正好有這個需求,特此記錄下來;
我們知道失敗的數據都會存到cap.received表中,處理思路就是從這個表中取出來數據,進行處理后,再發布出去,讓消費端重新消費掉這個數據。
我們首先翻源碼可以知道這樣一個模型類
查找引用,可以看到有這些每個存儲數據庫下都有一個Message的處理方法, 隨便點進去一個再查找引用
找到了這樣一段,就是提供用來搜索的。
可以根據此,把IDataStorage注入到控制器里面, 查找到失敗的信息