masstransit - 如何使用 Bus.Factory.CreateUsingRabbitMq 配置 Mass Transit Courier？

Question

我正在使用 Mass Transit 版本 7，我遇到了一个问题，我应该注意我是 Mass Transit 的初学者，所以请原谅我的简单问题。我的问题是如何使用 Bus.Factory.CreateUsingRabbitMq配置 Mass Transit Courier 。

Answer 1

要在不使用容器的情况下配置活动，请使用补偿和执行活动主机的特定方法。如果您需要指定活动工厂方法或其他配置端点，则有不同的重载。

Bus.Factory.CreateUsingRabbitMq(cfg =>
{
    cfg.Host(...);

    Uri compensateAddress = default;

    cfg.ReceiveEndpoint("activity-compensate", x =>
    {
        x.CompensateActivityHost<TActivity, TLog>();

        compensateAddress = x.InputAddress;
    });

    cfg.ReceiveEndpoint("activity-execute", x =>
    {
        x.ExecuteActivityHost<TActivity, TArguments>(compensateAddress);
    });
});