Wie setze ich den Rebus-Transaktionskontext für einen Web-Service?

Question

Da ich einen Web/SOAP-Service habe, wie richte ich einen richtigen Transaktionskontext für Rebus (den Messaging-Bus) ein und löse ihn aus? Wenn Rebus einen Message-Handler aufruft, ist dies kein Problem, da Rebus den Transaktionskontext vor dem Aufruf des Handlers einrichten wird - aber was ist mit dem Gegenteil, wenn ein Web-Service-Handler eine Nachricht über Rebus senden/veröffentlichen muss?

Ich bin nicht daran interessiert, wie man ein HTTP-Modul oder ähnliches implementiert - nur die Grundlagen rund um Rebus: Was ist nötig, um Rebus für das Senden einer Nachricht vorzubereiten?

Der Web-Service-Code hat eine eigene Transaktion, wenn er mit der Anwendungsdatenbank kommuniziert. Ich muss in der Lage sein, Rebus einzurichten, wenn ich die Datenbanktransaktion einrichte und Rebus commit/rollback, wenn ich dasselbe mit der Datenbank mache.

Ich habe ein ähnliches Problem mit Standalone-Befehlszeilenprogrammen, die sowohl Interaktion mit einer Datenbank und Senden von Rebus-Nachrichten benötigt.

Answer 1

Rebus wird Sende- und Veröffentlichungsvorgänge automatisch in seinem eigenen "Umgebungstransaktionskontext" eintragen, auf den über die statische Eigenschaft (*) AmbientTransactionContext.Current zugegriffen wird.

Sie könnten ITransactionContext selbst implementieren, wenn Sie wollten, aber Rebus kommt mit DefaultTransactionContext in der Box.

Sie verwenden es wie folgt aus:

using(var context = new DefaultTransactionContext()) 
{ 
    AmbientTransactionContext.Current = context; 

    // send and publish things in here 

    // complete the transaction 
    await context.Complete(); 
} 

, die leicht zum Beispiel genommen werden konnte in einer OWIN-Middleware oder ähnlichem.

---

(*) Das Objekt ist statisch, aber der zugrunde liegende Wert wird auf den aktuellen Ausführungskontext gebunden (durch CallContext.LogicalGet/SetData verwendet wird), was bedeutet, dass Sie daran denken können als fades gebunden, mit der schönen Eigenschaft, dass es fließt wie erwartet in Fortsetzungen.

In Rebus 2.0.2 ist es möglich, die Zugriffsmethoden anpassen verwendet, um den Kontext zu bekommen/Set von AmbientTransactionContext.SetAccessors(...) mit einem Action<ITransactionContext> Aufruf und einem Func<ITransactionContext>, z.B. wie folgt aus:

AmbientTransactionContext.SetAccessors(
    context => { 
     if (HttpContext.Current == null) { 
      throw new InvalidOperationException("Can't set the transaction context when there is no HTTP context"); 
     } 
     HttpContext.Current.Items["current-rbs-context"] = context 
    }, 
    () => HttpContext.Current?.Items["current-rbs-context"] as ITransactionContext 
); 

in diesem Fall, die sie in einer Art und Weise macht Arbeit, die richtig selbst fließt, wenn alte Schule HTTP-Modulen;)