问题描述
我使用的是大众交通第 7 版,但遇到了一个问题,我应该注意到我是大众交通的初学者,所以请原谅我的简单问题。 我的问题是如何使用 Bus.Factory.CreateUsingRabbitMq 配置大众运输 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);
});
});