未知交换类型 'x-delay-message' RabbitMq 与 MassTransit

Question

我已经安装好了'RabbitMQ Delayed Message Plugin'。并且可以在 RabbitMq 的插件列表中看到。

并使用以下代码使用 RabbitMq 配置 MassTnasit：

var services = new ServiceCollection();

        services.AddMassTransit(x =>
        {
            x.AddRabbitMqMessageScheduler();

            x.UsingRabbitMq((context, cfg) => 
            {
                cfg.UseDelayedExchangeMessageScheduler();

                cfg.ConfigureEndpoints(context);
            });
        });

并向我的业务服务注入 'IMessageScheduler' 接口并调用 'IMessageScheduler.ScheduledPublish<>()'。
但是我得到了这个错误：unknown exchange type 'x-delay-message' RabbitMq with MassTransit

Answer 1

对于该版本的 RabbitMQ，您需要最新版本的插件，即 available on GitHub。

我也已将 MassTransit Docker 图片更新为最新版本：MassTransit/RabbitMQ

未知交换类型 'x-delay-message' RabbitMq 与 MassTransit

unknown exchange type 'x-delay-message' RabbitMq with MassTransit

rabbitmq

schedule

masstransit