通过streadway模块在golan中创建队列仲裁rabbitmq

积累知识，胜过积蓄金银！毕竟在Golang开发的过程中，会遇到各种各样的问题，往往都是一些细节知识点还没有掌握好而导致的，因此基础知识点的积累是很重要的。下面本文《通过streadway模块在golan中创建队列仲裁rabbitmq》，就带大家讲解一下知识点，若是你对本文感兴趣，或者是想搞懂其中某个知识点，就请你继续往下看吧~

我想使用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

正确答案

您需要使用 QueueDeclare 函数来声明一个带有参数的队列，然后才能使用它。

args := Table{"x-queue-type": "quorum"}
channel.QueueDeclare(queue.Name,
    true,   // durable
    false,  // autoDelete
    false,  // exclusive
    false,  // wait for response
    args    // queue arguments
)

今天关于《通过streadway模块在golan中创建队列仲裁rabbitmq》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！