Masstransit Saga还款

Question

我想使用独立的quartz调度器为状态机saga设置消息调度重新传递。现在它在普通消费者中工作得很好，但我不能正确地为saga设置redelivering。我的saga配置如下所示：

MassTransit.Bus.Factory.CreateUsingRabbitMq(cfg =>
        {
            var retryPolicy = Retry.Incremental(5, TimeSpan.FromSeconds(5), TimeSpan.FromSeconds(2));

            cfg.UseMessageScheduler(new Uri($"rabbitmq://localhost/SchedulerQueue"));

            var host = cfg.Host(new Uri(uri), h =>
            {
                h.Username(config.RabbitMqUser);
                h.Password(config.RabbitMqPassword);
            });

            cfg.ReceiveEndpoint(host, "SagaQueue", e =>
            {
                e.Durable = true;

                e.StateMachineSaga(new MySaga(),
                    repository, c =>
                    {
                        c.UseTransaction();
                        c.Message<ISagaEvent>(y => y.UseScheduledRedelivery(retryPolicy));
                    });
            });
        });

其中ISagaEvent是由saga处理的消息。我是不是做错了什么，有没有办法为saga配置预定的重新交付？

Answer 1

要在saga中进行调度，通常最好使用实际的状态机调度特性，因此saga的状态会被更新以指示重新交付。

从本质上讲，如果您接收到的事件处于尚未准备好的状态，请使用Schedule()将消息安排在将来saga可能处于可以处理的状态的某个时间。

文档中有一个很好的时间表示例：http://masstransit-project.com/MassTransit/advanced/sagas/automatonymous.html