Question: What happened with rabbitmq.WithConsumeOptionsQuorum

[TheoAbiel]

Hello! I am using a quorum and I don't know how to use it anymore with the new version 0.11.0. Can you please guide me on how to do it?

[aaqaishtyaq]

Hey @TheoAbiel, To set a queue as a quorum queue, you can add queue args while starting a consumer.

args := rabbitmq.Table{
"x-queue-type": "quorum",
}

consumer, err := rabbitmq.NewConsumer(
    conn,
    func(d rabbitmq.Delivery) rabbitmq.Action {
        return rabbitmq.Ack
    },
    "my_queue",
         // ......
        rabbitmq.WithConsumerOptionsQueueArgs(args) // <--------------------- Args to set quorum queue
)

[aaqaishtyaq]

@wagslane, I was thinking of adding a new consumer option to set a queue as a quorum queue. Here is the implementation, Do let me know your thoughts.

[TheoAbiel]

Thank you very much! It works like a charm :grin: !