我们正在构建一个解决方案,将消息发布到超时队列。TTL 过期后的消息会被推送到主队列进行重新处理。
我们正在设置计数器值,以便将针对 x 号尝试消息。重新交付的次数。
解决方案工作正常。但是场景是当头部位置最高的消息 TTL 没有过期时,其他过期的消息不会被重新发布(到主队列)。
这种理解正确吗?如果是,解决方案是什么,以便在 TTL 之后重新处理每条消息。
欣赏答案/观点。
谢谢。
amqp rabbitmq spring-amqp rabbitmq-exchange
amqp ×1
rabbitmq ×1
rabbitmq-exchange ×1
spring-amqp ×1