我正在尝试掌握 ServiceBus 架构,并且正在使用 RawRabbit 1.10.4。为此,我正在学习使用 RawRabbit 的在线课程。在命令处理程序的注册中,创建了以下扩展方法,其中调用了 Methoc ctx.UseConsumerConfiguration。
Extension 方法应该在 RawRabbit.Pipe 命名空间中,该命名空间不可用。我需要安装什么 nuget 包以获取扩展方法,或者在 1.10.4 版中是否删除了此扩展方法/命名空间?
public static class Extensions
{
public static Task WithCommandHandlerAsync<TCommand>(this IBusClient bus,
ICommandHandler<TCommand> handler)
where TCommand : ICommand
=> bus.SubscribeAsync<TCommand>(msg => handler.HandleAsync(msg),
ctx => ctx.UseConsumerConfiguration(cfg => cfg.FromDelaredQueue(q => q.WithName("XXX"))));
}
