我已经安装了'RabbitMQ延迟消息插件‘。并且可以在RabbitMq的插件列表上看到。
并使用以下代码将MassTnasit配置为RabbitMq:
var services = new ServiceCollection();
services.AddMassTransit(x =>
{
x.AddRabbitMqMessageScheduler();
x.UsingRabbitMq((context, cfg) =>
{
cfg.UseDelayedExchangeMessageScheduler();
cfg.ConfigureEndpoints(context);
});
});
并将'IMessageScheduler‘接口注入到我的业务服务中,并调用'IMessageScheduler.ScheduledPublish<>()’。
但是我得到了一个错误:未知交换类型‘x-延迟消息’RabbitMq和MassTransit。
发布于 2021-05-02 12:09:28
对于该版本的RabbitMQ,您需要插件的最新版本,即可在GitHub上获得。
我还将MassTransit码头映像更新为最新版本:推车/拉比MassTransit
https://stackoverflow.com/questions/67354835
复制相似问题