rabbitmq 同时具有多个仲裁队列和常规(传统)队列

0h4hbjxa  于 2022-11-23  发布在  RabbitMQ
关注(0)|答案(1)|浏览(169)

在RabbitMQ集群中,我们是否可以同时拥有多个quorum类型的队列和多个其他常规(经典)类型的队列?如果可以,那么在Masstransit中,我如何将其中一些队列注册为quorum类型,而将其他队列注册为常规(经典)类型?
我写了下面的代码。但这段代码适用于所有队列:

public class ConfigureQuorumReceiveEndpoint: IConfigureReceiveEndpoint
{
    private const string QueueType = "x-queue-type";
    private const string QuorumQueue = "quorum";
    public void Configure(string name, IReceiveEndpointConfigurator configurator)
    {
        if (configurator is IRabbitMqReceiveEndpointConfigurator rabbitMqConfigurator)
        {
            rabbitMqConfigurator.SetQueueArgument(QueueType, QuorumQueue);
        }
    }
}

如何将其应用于某些特定队列?

up9lanfz

up9lanfz1#

name参数是接收端点名称(队列)-您可以使用它来确定是否希望该队列成为Quorum。

相关问题