如何解决MassTransit - 在路由单活动中重新传递消息
我正在使用大众运输 Courier 进行一个项目。我正在尝试重新发送消息以在 1 小时后重新执行活动。 这是我在执行活动方法中的代码:
await context.Redeliver(TimeSpan.FromMinutes(60));
var (success,message) = await client.performHttpRequest();
if(!success && context.GetRedeliveryCount() < 10))
{
await context.Redeliver(TimeSpan.FromMinutes(60));
}
但不是重新交付补偿开始。 我错过了什么?
解决方法
我所知道的使用路由单活动重新发送的唯一方法是使用 UseScheduledRedelivery
中间件。您可以抛出一个由中间件捕获的异常(您可以过滤异常类型,以仅重新传递某些类型),MassTransit 将为您处理重新传递。
例如,如果您抛出一个 RescheduleException
,您将按如下所示配置计划重新发送:
endpoint.UseScheduledRedelivery(r =>
{
r.Handle<RescheduleException>();
r.Intervals(TimeSpan.FromMinutes(5),TimeSpan.FromMinutes(15),TimeSpan.FromMinutes(30)));
});
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。