rebus - 检查正在进行的 rebus 处理程序并阻止 rebus 接受新消息

Question

我有一个 Web 应用程序，它使用 Rebus 和 Azure 服务总线队列作为传输。
它配置了 Simple Injector 容器。

在应用程序处理期间，我想阻止 rebus 接受新消息并检查目前正在处理的消息数。然后我可能决定等待几秒钟让处理程序完成。

这是可以实现的吗？

编辑:
我知道 SetWorkerShutdownTimeout 和 Advanced.Workers.SetNumberOfWorkers 方法的存在。我可以通过调用 Advanced.Workers.SetNumberOfWorkers(0) 来实现我的目标吗？

Answer 1

I may then decide to wait few seconds to allow handler to finish.

如果您处理总线(或容器，当您的应用程序关闭时您总是应该这样做，而容器又会处理总线)，默认情况下，当前正在处理的任何消息都将在 30 秒内完成处理。

关闭过程开始后将不会收到新消息。

Could I achieve what I aim by calling Advanced.Workers.SetNumberOfWorkers(0)?

是的 :) 如果你打电话

bus.Advanced.Workers.SetNumberOfWorkers(0);

工作线程将被删除，从而导致不再接收消息。

但是你应该知道，简单地处理你的 SimpleInjector 容器会给当前正在处理的所有消息一个完成的机会。