我似乎无法得到适用于RabbitMQ上的Mass Transit的Castle Windsor集成。一切都很好,直到我将温莎引入到图片中。我引用了Castle.Windsor 3.2和MassTransit.WindsorIntegration 2.9,并将容器配置为在我的应用程序中使用。我通过注册MassTransit消费者:MassTransit消费者在使用Windsor集成时从未调用
Container.Register(..., Types.FromThisAssembly().BasedOn<IConsumer>());
当我调试和这条线跑后检查容器,我可以看到它成功注册所有的消费者与所有我的其他组件一起。然后我有以下代码来初始化和注册服务总线:
var serviceBus = ServiceBusFactory.New(sbc =>
{
sbc.UseRabbitMq();
sbc.ReceiveFrom(Config.ServiceBusEndpoint);
sbc.Subscribe(sc => sc.LoadFrom(Container));
});
Container.Register(Component.For<IServiceBus>().Instance(serviceBus));
我使用由MassTransit.WindsorIntegration提供的LoadFrom(IWindsorContainer container)
扩展方法。
到目前为止,我发现的所有例子都停在这里,表明这是你应该做的所有事情。不幸的是对我来说,我的消费者永远不会被调用,消息只是堆积在队列中(最终超时并进入错误队列)。消息在消费者队列中显示出来的事实(+我看到一个消费者通过RabbitMQ管理工具绑定到队列中)向我表明消费者可能正在被正确订购 - 所以我不确定问题在于。
我为Windsor和MassTransit添加了NLog日志记录,但日志中没有显示错误。我不确定在这一点上我应该如何进行故障排除。有任何想法吗?
此外,此应用程序目前只是使用Topshelf进行开发的控制台应用程序。最终它将作为Windows服务安装。不知道这是否相关,但我想我会提及它以防万一。
UPDATE
作为测试我创建了一个非常简单的消费者与用于处理非常简单的测试消息中的参数的构造函数。此消费者已成功呼叫!然而,“真正的”消费者具有需要通过构造函数注入到它们中的依赖关系。我希望Container能够解决这些问题,但显然它存在一些麻烦。奇怪的是,在日志中没有任何东西显示它。敬请期待...