小编ams*_*tix的帖子

我正在寻找一个很好的解决方案来记录失败的消息,在超过重试限制之后,没有处理错误队列.到目前为止我发现了什么:

• 我可以从InMemoryInboundMessageTracker继承并覆盖IsRetryLimitExceeded,但此时除了id之外没有关于消息本身的信息.
• 我可以实现IInboundMessageInterceptor并在Pre/PostDispatch中获取IConsumeContext,但此时没有关于成功/失败的信息.

因此,作为一个解决方案,我可以在PreDispatch中获取IConsumeContext,将其置于某种缓存中,然后在超出重试限制时将其从IsRetryLimitExceeded中的缓存中取出.

方法按以下顺序调用:IsRetryLimitExceeded - > PreDispatch - > PostDispatch

所以我找不到从缓存中删除成功处理的消息的好地方.

当然我可以使用大小有限的缓存,但整个解决方案似乎很奇怪.

任何关于这个问题的想法将不胜感激.