【发布时间】:2021-06-20 22:48:32
【问题描述】:
我已经安装了“RabbitMQ 延迟消息插件”。并且可以在 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
【问题讨论】:
标签: rabbitmq schedule masstransit