MassTransit 处理 Saga 中的故障

Question

我正在尝试处理 Saga 实例中的特定 Fault，如 https://masstransit-project.com/MassTransit/usage/exceptions.html#faults 中所述。 在 myStateMachine 课程中，我有：

Event(
    () => OnError,
    x => x
        .CorrelateById(context => context.Message.Message.CorrelationId))

DuringAny(WhenError());

...

public Event<CustomCommand> CustomCommandReceived { get; protected set; }

public Event<Fault<CustomCommand>> OnError { get; protected set; }

...

private EventActivityBinder<RequestSaga, Fault<CustomCommand>> WhenError()
{
    return When(OnError)
        .Then(context =>
        {
            context.Instance.Status = RequestProcessingStatus.Error;
        });
}

但是当Fault<CustomCommand> 发生时，处理程序内的代码没有执行，Fault<CustomCommand> 消息进入..._skipped 队列。

我做错了什么？？

Answer 1

CustomCommands 是否在 Initial 状态下处理，并抛出异常？这将阻止保存 saga 实例，因此在发布故障后，将导致故障被忽略，因为 DuringAny 不包括 Initial 或 Final状态。如果要处理Initial状态的故障，需要显式添加。

Initially(WhenError());
DuringAny(WhenError());