Hello all Namekans™!
I’m trying to use Nameko in one of our production evironments and one of the most important things in our case is full HA (in context of RabbitMQ). RabbitMQ have a new way of mirroring queues, the quorum queues.
To declare a quorum queue set the x-queue-type queue argument to quorum (the default is classic). This argument must be provided by a client at queue declaration time; it cannot be set or changed using a policy. This is because policy definition or applicable policy can be changed dynamically but queue type cannot. It must be specified at the time of declaration.
Declaring a queue with an x-queue-type argument set to quorum will declare a quorum queue with up to five replicas (default replication factor), one per each cluster node.
Is it possible to implement this kind of queue with Nameko? I’m using Rabbit cluster in Kubernetes, so adding automation to expanding quorum for queues with
rabbitmq-queues add_member is highly unwanted. Of course I can implement some watcher, event publisher via API and automate this, but client side declaration is much more sexy.