如何解决如何在 MassTransit 中将 MessageData 存储库配置为服务?
我想将 IMessageDataRepository 注册为单独的服务,并将该服务与 MassTransit 的配置一起使用。实现这一点的一种方法是诉诸可怕的服务定位器模式:
public void ConfigureServices(IServiceCollection services)
{
...
using var serviceProvider = services.BuildServiceProvider();
var repository = serviceProvider.GetRequiredService<IMessageDataRepository>();
services.AddMassTransit(x =>
{
x.UsingRabbitMq((context,cfg) =>
{
cfg.UseMessageData(repository);
});
});
services.AddMassTransitHostedService();
...
}
有更好的方法吗?
解决方法
配置总线时,通过 UsingRabbitMq
,context 参数是服务提供者:
public void ConfigureServices(IServiceCollection services)
{
...
services.AddMassTransit(x =>
{
x.UsingRabbitMq((context,cfg) =>
{
cfg.UseMessageData(context.GetRequiredService<IMessageDataRepository>());
});
});
services.AddMassTransitHostedService();
...
}
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。