如何在MassTransit生产者端配置RabbitMQ Streams队列参数？

报错原因很明确：生产者进程发送消息时，MassTransit默认以classic类型声明队列，但该队列已被消费者端创建为stream类型，参数不匹配触发precondition_failed异常。

要解决这个问题，只需在生产者端的MassTransit配置中，为目标队列指定x-queue-type=stream的参数，确保队列声明时的参数与已存在的队列一致。

具体配置方法 #

方法1：在总线配置中为特定队列添加参数 #

即使生产者不消费该队列，也可以通过ReceiveEndpoint配置队列参数，让MassTransit在声明队列时使用正确的类型：

services.AddMassTransit(x =>
{
    x.UsingRabbitMq((context, cfg) =>
    {
        cfg.Host("rabbitmq://localhost/vhost_1");

        // 针对目标队列配置stream类型参数
        cfg.ReceiveEndpoint("MyCommand", e =>
        {
            e.SetQueueArgument("x-queue-type", "stream");
            // 生产者无需在这里配置消费者，仅需设置队列参数即可
        });
    });
});

方法2：发送消息时动态指定队列参数 #

如果需要在发送消息时灵活配置参数，可以在发送上下文里添加队列声明参数：

var sendEndpoint = await bus.GetSendEndpoint(new Uri("queue:MyCommand"));
await sendEndpoint.Send(new MyCommand(), context =>
{
    // 获取RabbitMQ模型上下文，添加队列参数
    var modelContext = context.GetPayload<ModelContext>();
    modelContext.QueueDeclareArguments["x-queue-type"] = "stream";
});

配置完成后，生产者端声明队列时会使用stream类型参数，与已存在的队列属性匹配，即可解决报错问题。

内容的提问来源于stack exchange，提问作者luke77