在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);
}
}
}
如何将其应用于某些特定队列?
1条答案
按热度按时间up9lanfz1#
name
参数是接收端点名称(队列)-您可以使用它来确定是否希望该队列成为Quorum。