利用streadway模块在golan中创建队列仲裁rabbitmq

00jrzges 于 2022-11-23 发布在 RabbitMQ

关注(0)|答案(1)|浏览(169)

嗨，我想用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 )

但队列类型为经典而不是仲裁

rabbitmq

来源：https://stackoverflow.com/questions/73670885/create-queue-quorum-rabbitmq-in-golan-by-streadway-module

1条答案

按热度按时间

yvfmudvl1#

您需要使用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上的问题。

赞(0）回复(0）举报 2022-11-23

我来回答

利用streadway模块在golan中创建队列仲裁rabbitmq

1条答案

相关问题

热门标签

最新问答