RabbitMQ auto-delete queues with timeouts

Question

I have a k8s service, using rabbitMQ as message broker. I want to be able to delete a specific queue if the service deployment which may have multiple pods is stopped.

Reading the documentation RabbitMq Queues Docs I found that the best case for me in this case is to use the auto-deleted property of the queue.

Is there any option so the auto-deleted queue will not be deleted immediately after the clients are disconnected, instead to wait some seconds to wait for reconnection ?

learner · Accepted Answer · 2024-01-04 09:46:26Z

0

Set expires policy on queues as per https://www.rabbitmq.com/ttl.html#queue-ttl.

rabbitmqctl set_policy ZeroConsumerQueExpiry "myProjectQueue.*" '{"expires":10000}' --apply-to queues

It will support your use case in following ways

waits for reconnection for 10 seconds
Auto Deletes Queue if no consumer connects or reconnects for 10 seconds

There will be a difference in using auto-delete vs expires policy

Auto-delete will not delete an inactive queue unless a consumer connects to it
expires policy will will delete the queue whether a consumer has ever connected or never connected. Only catch is that within if there is no activity for given milliseconds, the queue gets deleted.

answered Jan 4, 2024 at 9:46

learner

9502 gold badges12 silver badges39 bronze badges

Sign up to request clarification or add additional context in comments.

Collectives™ on Stack Overflow

RabbitMQ auto-delete queues with timeouts

1 Answer 1

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Related