castle-windsor - Rebus,使用 Castle Windsor 和 Rebus
问题描述
我正在尝试将 Rebus 与 Azure Service Bus 和 Castle Windsor 一起使用。当我使用没有 Castle Windsor 的代码版本时,会正确创建队列和主题:
public static void Main(string[] args)
{
using (var activator = new BuiltinHandlerActivator())
{
activator.Register(() => new SomeMessageHandler());
activator.Register(() => new BusItemMessageHandler());
Configure.With(activator)
.Logging(l => l.ColoredConsole(minLevel: LogLevel.Warn))
.Transport(t => t.UseAzureServiceBus(GetConnectionString(), "ReceiverInputQueue"))
.Start();
activator.Bus.Subscribe<SomeMessage>().Wait();
activator.Bus.Subscribe<IBusItem>().Wait();
Console.ReadLine();
Console.WriteLine("Quitting...");
}
}
..但是当我尝试使用温莎城堡时,只创建了队列(没有主题):
public static void Main(string[] args)
{
using (var container = new WindsorContainer())
{
//container.Register(Classes.FromAssemblyContaining<BusItemMessageHandler>()
// .BasedOn<IHandleMessages>()
// .WithServiceAllInterfaces()
// .LifestyleTransient());
container.AutoRegisterHandlersFromAssemblyOf<BusItemMessageHandler>();
var adapter = new CastleWindsorContainerAdapter(container);
Configure.With(adapter)
.Logging(l => l.ColoredConsole(minLevel: LogLevel.Warn))
.Transport(t => t.UseAzureServiceBus(GetConnectionString(), "ReceiverInputQueue"))
.Start();
Console.WriteLine("Press ENTER to quit");
Console.ReadLine();
Console.WriteLine("Quitting...");
}
}
这里的消息/处理程序:
public class BusItemMessageHandler : IHandleMessages<IBusItem>
{
public async Task Handle(IBusItem message)
{
var a = message;
}
}
public class SomeMessageHandler : IHandleMessages<SomeMessage>
{
public async Task Handle(SomeMessage message)
{
Console.WriteLine($"Got string: {message.Message}");
}
}
public class SomeMessage : IBusItem
{
public Guid BusItemId { get; set; } = Guid.NewGuid();
public DateTime Timestamp { get; set; } = DateTime.UtcNow;
public string Message { get; set; }
}
怎么了?有什么建议么?谢谢!
解决方案
使用 Rebus 和 Azure 服务总线,主题是在
a) 发布者首先向其发布,或 b) 订阅者首先订阅它
当我比较你的两个代码片段时,这两行与
activator.Bus.Subscribe<SomeMessage>().Wait();
activator.Bus.Subscribe<IBusItem>().Wait();
片段#2中缺少。
如果你这样做:
var bus = container.Resolve<ISyncBus>(); //< NOTE: SYNC BUS!
bus.Subscribe<SomeMessage>();
我打赌你会得到预期的主题!
PS:订阅IBusItem
没有任何效果,除非你修改 Rebus 如何将 .NET 类型映射到主题。当您发布 的实例时SomeMessage
,它将发布到以该类型命名的主题(例如,类似SomeNamespace.SomeMessage__SomeAssembly
)。
不过,您仍然可以使用处理程序实现IHandleMessages<IBusItem>
。多态调度机制在收到消息后启动,因此只要您订阅了所有必要的类型,调度机制就会调度到所有兼容的处理程序。
推荐阅读
- javascript - IFrame 和 iOS 问题
- powershell - Powershell UAC绕过计划任务失败
- c - C float 初始化结果出乎意料
- r - 编织我的 r markdown 文档时遇到问题
- .htaccess - 使用 htaccess 将 https 重定向到 http
- python - IndexError:仅在使用 SSH 时列出索引超出范围错误消息
- javascript - 使用 Interact JS 调整大小
- android - Ionic 3 Livereload 无法在 Android 设备上运行
- python-3.x - 在python中打印unicode字符
- react-native - Native Base Toast 在实时模式下不起作用