如何在 ServiceStack Redis MQ 中添加处理失败消息的延迟
How could I add a delay in processing failed messages in ServiceStack Redis MQ
有没有一种简单的方法可以让 Servicestack 在重试失败的 MQ 项目之前等待 x 秒(使用 Redis MQ)。目前它只是连续尝试3次,没有延迟。
当您注册 MQ 处理程序时,您还可以注册一个错误处理程序,它在发布失败消息后被调用,您可以使用它来添加自定义延迟,例如:
mqServer.RegisterHandler<MyRequest>(
ServiceController.ExecuteMessage,
(msgHandler, msg, ex) => Thread.Sleep(1000));
有没有一种简单的方法可以让 Servicestack 在重试失败的 MQ 项目之前等待 x 秒(使用 Redis MQ)。目前它只是连续尝试3次,没有延迟。
当您注册 MQ 处理程序时,您还可以注册一个错误处理程序,它在发布失败消息后被调用,您可以使用它来添加自定义延迟,例如:
mqServer.RegisterHandler<MyRequest>(
ServiceController.ExecuteMessage,
(msgHandler, msg, ex) => Thread.Sleep(1000));