如何解决MassTransit IBusControl.ScheduleRecurringSend 为相同类型的预定事件生成相同的 MessageId
我有一个控制台应用程序,用于在大众运输中使用石英调度。相关代码位于 IHostedService 的 Task StartAsync(CancellationToken cancellationToken)
实现中。
看起来像下面的代码
await _bus.ScheduleRecurringSend(new Uri($"queue_uri"),new CustomMessageSchedule(),new CustomMessage(),cancellationToken: cancellationToken);
var scheduler = await _schedulerFactory.GetScheduler(cancellationToken);
scheduler.JobFactory = new MassTransitJobFactory(_bus,_jobFactory);
await scheduler.Start(cancellationToken);
预定消息已成功发布到队列,但这些消息获得相同的 messageId。这会在消费者方面造成一些问题。
我必须使用 IFilter<SendContext<CustomMessage>>
实现,但没有成功。也许我没有正确使用它,但我什至不确定这是否是正确的方法。
对此事有什么建议吗?
解决方法
除了包含一些额外的消息头之外,Quartz 在发送之前不会修改预定消息。为重复消息生成一个新的 MessageId
可能是有意义的(因为它们不像定期调度的消息那样是一次性的调度消息)。
但是,截至目前,行为符合预期。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。