我很难找到一种方法来延迟SpringAMQP中的消息级别。如果服务不可用或抛出异常,我会调用keep服务,我会将所有请求存储到RabbitMQ队列中,并不断重试服务调用,直到它成功执行。如果服务持续抛出错误或不可用,rabbitMQ侦听器将继续循环。(这意味着侦听器检索消息并进行服务调用,如果出现任何错误,则将消息重新排队)
我使用MessagePostProcessor限制循环到X小时,但是我想在消息级别上启用延迟,并在每次尝试访问服务时启用延迟。例如,第一次尝试延迟3000ms,第二次尝试6000ms,依此类推,直到我尝试x次。
如果你能提供一些例子,那就太好了。
你能给我一些关于这方面的想法吗?
https://stackoverflow.com/questions/38236878
复制相似问题