滷麪送在TransactionScope的

Question

這在以前滷麪的（< = 0.84.0）版本中的TransactionScope發送的信息是可能的，如果範圍完成

using (var scope = new TransactionScope()) 
{ 
    var ctx = new AmbientTransactionContext(); 
    sender.Send(recipient.InputQueue, msg, ctx); 

    scope.Complete(); 
} 

是否有可能才達到同樣的也就只有送在Rebus2中的行爲

Answer 1

正如您已經正確發現的那樣，Rebus版本> = 0.90.0不會自動在環境事務中登記。

（UPDATE：爲0.99.16，所期望的行爲就可以了 - 看到這個答案的詳細信息，到底如何）

然而，這並不意味着滷麪不能在一個事務中登記 - 它只是使用自己的環境事務機制（不依賴於System.Transactions，並且在Rebus移植到.NET核心時可用）。

您可以使用滷麪DefaultTransactionContext和‘使其環境’這一AmbientRebusTransactionContext：

/// <summary> 
/// Rebus ambient transaction scope helper 
/// </summary> 
public class AmbientRebusTransactionContext : IDisposable 
{ 
    readonly DefaultTransactionContext _transactionContext = new DefaultTransactionContext(); 

    public AmbientRebusTransactionContext() 
    { 
     if (AmbientTransactionContext.Current != null) 
     { 
      throw new InvalidOperationException("Cannot start a Rebus transaction because one was already active!"); 
     } 

     AmbientTransactionContext.Current = _transactionContext; 
    } 

    public Task Complete() 
    { 
     return _transactionContext.Complete(); 
    } 

    public void Dispose() 
    { 
     AmbientTransactionContext.Current = null; 
    } 
} 

然後你就可以使用這樣的：

using(var tx = new AmbientRebusTransactionContext()) 
{ 
    await bus.Send(new Message()); 

    await tx.Complete(); 
} 

，或者，如果你使用它在一個web應用程序中，我建議你把它包裝在這樣的OWIN中間件中：

app.Use(async (context, next) => 
{ 
    using (var transactionContext = new AmbientRebusTransactionContext()) 
    { 
     await next(); 

     await transactionContext.Complete(); 
    } 
}); 

UPDATE：既然滷麪0.99.16，下面已經支持（通過Rebus.TransactionScope包）：

using (var scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled)) 
{ 
    scope.EnlistRebus(); //< enlist Rebus in ambient .NET tx 

    await _bus.SendLocal("hallå i stuen!1"); 

    scope.Complete(); 
}