英文:
create queue quorum rabbitmq in golan by streadway module
问题
你好，我想用GO语言在Rabbitmq中创建一个名为"Quorum"的队列，并且我写了下面的代码：
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
)
但是队列的类型是"classic"而不是"quorum"。
英文:
hi i want create queue Quorum in Rabbitmq with GO
and i write this code below
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
答案1
得分: 3
你需要使用QueueDeclare函数在消费之前声明一个带有参数的队列。
args := Table{"x-queue-type": "quorum"}
channel.QueueDeclare(queue.Name,
true, // durable
false, // autoDelete
false, // exclusive
false, // wait for response
args // queue arguments
)
注意：RabbitMQ团队会监控rabbitmq-users邮件列表，有时会在StackOverflow上回答问题。
英文:
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
)
<sub><b>NOTE:</b> the RabbitMQ team monitors the rabbitmq-users mailing list and only sometimes answers questions on StackOverflow.</sub>
通过集体智慧和协作来改善编程学习和解决问题的方式。致力于成为全球开发者共同参与的知识库，让每个人都能够通过互相帮助和分享经验来进步。
评论