我有一个 Web 应用程序,它使用 Rebus 和 Azure 服务总线队列作为传输。
它配置了 Simple Injector 容器。
在应用程序处理期间,我想阻止 rebus 接受新消息并检查目前正在处理的消息数。然后我可能决定等待几秒钟让处理程序完成。
这是可以实现的吗?
编辑:
我知道 SetWorkerShutdownTimeout 和 Advanced.Workers.SetNumberOfWorkers 方法的存在。我可以通过调用 Advanced.Workers.SetNumberOfWorkers(0) 来实现我的目标吗?
最佳答案
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 容器会给当前正在处理的所有消息一个完成的机会。
关于rebus - 检查正在进行的 rebus 处理程序并阻止 rebus 接受新消息,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/47712293/