Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

create queue quorum rabbitmq in golan by streadway module

I want to create queue Quorum in Rabbitmq with GO and I wrote this code:

deliveries, err := c.channel.Consume(
    queue.Name, // name
    c.tag,      // consumerTag,
    false,      // noAck
    false,      // exclusive
    false,      // noLocal
    false,      // noWait
    amqp.Table{
        "x-queue-type": "quorum",
    }, // arguments )

but queue made of type classic not quorum

like image 902
Ali Bagheri Avatar asked Jan 20 '26 20:01

Ali Bagheri


1 Answers

You need to use the QueueDeclare function to declare a queue with arguments before you consume from it.

args := Table{"x-queue-type": "quorum"}
channel.QueueDeclare(queue.Name,
    true,   // durable
    false,  // autoDelete
    false,  // exclusive
    false,  // wait for response
    args    // queue arguments
)
like image 73
Luke Bakken Avatar answered Jan 23 '26 20:01

Luke Bakken