【发布时间】:2021-02-16 22:16:19
【问题描述】:
我正在使用 Mass Transit 版本 7,我遇到了一个问题,我应该注意我是 Mass Transit 的初学者,所以请原谅我的简单问题。 我的问题是如何使用 Bus.Factory.CreateUsingRabbitMq 配置公共交通 Courier。
【问题讨论】:
标签: masstransit courier
我正在使用 Mass Transit 版本 7,我遇到了一个问题,我应该注意我是 Mass Transit 的初学者,所以请原谅我的简单问题。 我的问题是如何使用 Bus.Factory.CreateUsingRabbitMq 配置公共交通 Courier。
【问题讨论】:
标签: masstransit courier
要在不使用容器的情况下配置活动,请使用特定方法补偿和执行活动主机。如果您需要指定活动工厂方法或其他配置端点,则有不同的重载。
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);
});
});
【讨论】: