.NET Core CAP失败事件的处理


CAP默认有失败重试机制,达到50次后就不再重试;

那么对于这种仍然失败的数据我们该怎么处理呢? 工作中正好有这个需求,特此记录下来;

 

我们知道失败的数据都会存到cap.received表中,处理思路就是从这个表中取出来数据,进行处理后,再发布出去,让消费端重新消费掉这个数据。

 

我们首先翻源码可以知道这样一个模型类

 

 查找引用,可以看到有这些每个存储数据库下都有一个Message的处理方法, 随便点进去一个再查找引用

 

 找到了这样一段,就是提供用来搜索的。 

 

 可以根据此,把IDataStorage注入到控制器里面, 查找到失败的信息


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM