中止 MassTransit Saga 的活动链

问题描述

我正在尝试弄清楚如何中止一系列活动，如果一个活动确定有问题，则应该完成 Saga。

例如：

Initially(
    When(UpdateRequested)
        .Activity(x => x.OfType<InitialSetup>())
        .Activity(x => x.OfType<StartUpdating>())
        .TransitionTo(Updating)

InitialSetup 将根据从数据库加载的一些信息来配置 Saga。让我们让它意识到缺少所需的数据，并且应该在运行 StartUpdating 活动之前完成 Saga。

我怎样才能做到这一点？

解决方法

你可以抛出一个异常，捕获它，然后使用 catch 分支来完成这个 saga。

Initially(
    When(UpdateRequested)
        .Activity(x => x.OfType<InitialSetup>()) // activity throws
        .Activity(x => x.OfType<StartUpdating>())
        .TransitionTo(Updating)
        .Catch<MissingDataException>(x => x.Finalize())
);

automatonymous masstransit