.NET Core CAP失败事件的处理

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

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

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

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

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

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

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

原文地址:https://www.cnblogs.com/mchuang/p/13509306.html