java - RabbitMQ moving messages from 1 Queue to another -
i using rabbitmq in java application.
i want move messages 1 queue queue.
the answer found here helpful me is possible move / merge messages between rabbitmq queues?.
but on running command, there's no success or failure message.
how can ensure during runtime? command using
rabbitmqctl set_parameter shovel my-shovel '{"src-uri": "amqp://localhost", "src-queue": "myqueue", \ "dest-uri": "amqp://localhost", "dest-queue": "test3"}'
and output
setting runtime parameter "my-shovel" component "shovel" "{\"src-uri\": \"amqp://localhost\", \"src-queue\": \"myqueue\", \"dest-uri\": \"amqp://localhost\", \"dest-queue\": \"test3\"}" ...
another way set rabbitmq policy time live or size on queue. then, setup policy handle messages should go. expire messages out of first queue , send them second queue. reference how here , here.
Comments
Post a Comment