rebus - 如何从 Rebus 检查错误队列

Question

我有一个运行良好的输入队列。有时一条消息会进入错误队列。现在我希望能够检查这些消息，如果我知道这条特定消息会通过，可能会再次将它们转发到输入队列。

如何开始检查错误队列？有什么最佳实践吗？我不能只执行 .CreateBus().Start()，因为这会触发来自普通处理程序的处理程序。

Answer 1

检查队列的方式和获得的选项取决于所选的传输方式。

如果您将 Rebus 与 MSMQ 一起使用，检查队列(输入队列、错误队列、MSMS 死信队列)和重试失败消息传递的最简单方法是启动 Rebus Snoop . Rebus 也有一个 ReturnToSourceQueue CLI tool for MSMQ。

如果您使用的是 Azure 服务总线，我可以推荐 Paolo Salvatori's Service Bus Explorer，我自己在几个项目中使用过它。

对于 RabbitMQ，我通常使用 RabbitMQ 内置的 Web 管理插件来检查队列，然后 Rebus 也带有一个 ReturnToSourceQueue CLI tool for RabbitMQ。

如果您使用的是 SQL Server，我建议启动 SQL Server Management Studio 并启动 SQL-fu ;)

如果你想编写一些代码来自动转发或处理失败的消息，我可以推荐使用 Rebus 的传输实现(即 MsmsMessageQueue(以及 MsmqUtil)、RabbitMqMessageQueue、AzureServiceBusMessageQueue 等)来处理原始传输消息的接收和发送——这是我自己多次使用的方法，例如实现粗略的二级重试机制和失败消息的转发和归档等。