Rebus：如何在不处理总线实例的情况下 stop/start 消息处理？

Question

我遇到这样一种情况，我需要在使用 Rebus 和 Azure 服务总线的应用程序实例中暂停消息处理。

应用程序的生命周期在应用程序启动时配置IoC容器，然后在应用程序准备好开始处理消息时配置并启动Rebus，自动将Rebus及其依赖添加到IoC容器中。

在应用程序生命周期的后期，它可能需要暂停消息处理，然后再次开始消息处理，而无需重新启动应用程序。

在我当前的实验中，我尝试在需要暂停消息处理时处理 IBus，但我不处理 IoC 容器 (Windsor)，因为其他组件在暂停期间需要它。我得到的结果是 InvalidOperationException

System.InvalidOperationException 
Attempted to register primary -> Rebus.Config.Options, but a primary registration already exists: primary -> Rebus.Config.Options
   at Rebus.Injection.Injectionist.Register[TService](Func`2 resolverMethod, Boolean isDecorator, String description)
   at Rebus.Config.RebusConfigurer.Start()

重新配置并再次启动总线时，将重用相同的容器实例。由于一些 Rebus 依赖项已经在容器中注册，因此似乎会发生异常。所以我需要一些其他方法来停止消息处理而不处理 IBus 实例。

是否可以在应用程序的生命周期内 pause/start 消息处理？查看 IBus api 或 IAdvancedApi 我找不到合适的方法来实现这一点。

Answer 1

这很容易，当你知道的时候：你可以简单地将工作线程数设置为 0，这将停止消息处理：

// blocks until all currently executing message handlers have finished
// what they're currently up to
bus.Advanced.Workers.SetNumberOfWorkers(0);

然后通过将它们添加回来再次恢复消息处理：

// you should probably get the number from a configuration
// value somewhere
bus.Advanced.Workers.SetNumberOfWorkers(3);

Rebus：如何在不处理总线实例的情况下 stop/start 消息处理？

Rebus: how to stop/start message processing without disposing bus instance?

azureservicebus

rebus