CODEWITHSUNDEEP
javarabbitmqmessage-queue
Anil Kumar
Anil Kumar

Reputation: 2741

RabbitMQ moving messages from 1 Queue to another

I am using RabbitMQ in my java application.

I want to move messages from 1 queue to another queue.

The answer that i found here is helpful for me Is it possible to move / merge messages between RabbitMQ queues?.

But on running that command, there's no success or failure message.

How can i ensure this during runtime? The command I am using

rabbitmqctl set_parameter shovel my-shovel '{"src-uri": "amqp://localhost", "src-queue": "myQueue", \
 "dest-uri": "amqp://localhost", "dest-queue": "test3"}'

And the output

Setting runtime parameter "my-shovel" for component "shovel" to "{\"src-uri\": \"amqp://localhost\", \"src-queue\": \"myQueue\", \"dest-uri\": \"amqp://localhost\", \"dest-queue\": \"test3\"}" ...

Upvotes: 2

Views: 3853

Answers (2)

froeschli
froeschli

Reputation: 2880

If you have the rabbitmq_shovel_management plugin enabled, you can view the configured shovels and their status in the web-management console under the ADMIN tab.

Upvotes: 0

joshuad2
joshuad2

Reputation: 317

Another way to do this is to set a RabbitMQ policy for Time To Live or Size on the Queue. Then, setup up a policy to handle where the messages should go. This will expire the messages out of the first queue and send them to the second queue. The reference for how to do this is here and here.

Upvotes: 2

Related Questions