我在我的 java 应用程序中使用 RabbitMQ。
我想将消息从一个队列移动到另一个队列。
我在这里找到的答案对我有帮助 Is it possible to move / merge messages between RabbitMQ queues? .
但是在运行该命令时，没有成功或失败消息。
如何在运行时确保这一点？ 我正在使用的命令
rabbitmqctl set_parameter shovel my-shovel '{"src-uri": "amqp://localhost", "src-queue": "myQueue", \
"dest-uri": "amqp://localhost", "dest-queue": "test3"}'
和输出
Setting runtime parameter "my-shovel" for component "shovel" to "{\"src-uri\": \"amqp://localhost\", \"src-queue\": \"myQueue\", \"dest-uri\": \"amqp://localhost\", \"dest-queue\": \"test3\"}" ...
最佳答案
执行此操作的另一种方法是为队列上的生存时间或大小设置 RabbitMQ 策略。然后，设置策略来处理消息的去向。这将使第一个队列中的消息过期并将它们发送到第二个队列。有关如何执行此操作的引用是 here和 here .
关于java - RabbitMQ 将消息从 1 个队列移动到另一个队列，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/31589637/