c# - MassTransit 事务性发布

Question

我不知道如何使用 MassTransit 3.1.2 和 RabbitMQ 3.6.0 发布事务性消息。我有一个基本场景，我将一些东西保存到数据库，然后我想发布一个事件。在它周围包装一个 System.Transactions.TransactionScope 不起作用，在我完成范围之前消息已经发送:

using (var scope = new TransactionScope(TransactionScopeOption.Required))
{
     // Save to database here.

     bus.Publish(new EntityCreatedEvent());

     // Event is already published at this point.

     scope.Complete();
}

总线创建如下:

var rabbitMqHostAddress = new Uri($"rabbitmq://{ConfigurationManager.AppSettings["RabbitMqHost"]}/");

var bus = Bus.Factory.CreateUsingRabbitMq(r =>
{
    r.Host(rabbitMqHostAddress, h =>
    {
        h.Username(ConfigurationManager.AppSettings["RabbitMqUsername"]);
        h.Password(ConfigurationManager.AppSettings["RabbitMqPassword"]);
    });
});

Answer 1

RabbitMQ 不注册事务。这不可能。