java - RabbitMQ 消费者是否可以配置为仅使用同一消息的定义次数的尝试

标签 java rabbitmq amqp

RabbitMQ 在某种程度上是否有能力,我可以定义我的消费者,它有消费相同消息的限制。即我的消费者使用 enqueue=true 进行基本的拒绝。并且它会无限地继续监听相同的消息。我不是在谈论队列端的 TTL。但是对消费者的控制/配置告诉我只想使用它 5 次,然后将其发送到另一个队列。这可以实现吗?

最佳答案

所以是的,我相信这是可以做到的。您将需要缓存收到的消息的传递标签,并跟踪拒绝计数。一旦特定消息的拒绝计数大于 5,则将该消息发布到另一个队列。您还需要向 RabbitMQ 确认收到的消息,并可能创建一条新消息(带有新的传递标签)并发布它。

关于java - RabbitMQ 消费者是否可以配置为仅使用同一消息的定义次数的尝试,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/18261702/

相关文章:

rabbitmq - 如何在 Rabbitmq 中设置消息的基本消息属性?

python - Django Celery 任务成功但客户端等待

excel - 如何在 Excel 中进行分布式计算

java - 如何使用字符串替换方法而不替换为空字符串?

java - java中如果字符串后面有两个或多个空格/空格,如何分割字符串?

java - 查找 JNDI/LDAP 连接安全协议(protocol)

symfony - 我应该如何构建 dockerized RabbitMQ?

Java Mysql更新语句

c++ - AMQP-CPP > 处理程序中的错误文件描述符

c# - Azure 服务总线,我的本地计算机上的传出消息在哪里?