XA Kontext für immutante Listener

Question

Ich versuche, immutant zu verwenden, um Transaktionen über HornetQ und mysql zu verwalten. Wie ich die Dokumente verstehe, muss ich XA-Transaktionen verwenden, da ich eine eigenständige App betreibe und nicht in einem App-Server.

Aber wenn ich versuche und setze: xa? Für den Kontext meiner Anwendung erhalte ich Ausnahmen, wenn ich binde, um einen Listener einzurichten.

(ns example 
    (:require [immutant.messaging :as msg])) 

(def capture (atom nil)) 
(let [ctx (msg/context :host "localhost" :xa? true) 
     queue (msg/queue "example" :context ctx)] 
    (reset! capture nil) 
    (msg/listen queue (fn [m] (reset! capture m))) 
    (msg/publish queue {:my :msg})) 

Dies wirft „java.lang.IllegalStateException: Sie kein Kind Zusammenhang von einem XA Kontext schaffen.“ aus dem Aufruf (msg/listen). Was mache ich falsch?

Answer 1

Ich denke, Sie haben eine bug entdeckt, aber in Ihrem Fall, ich denke, es gibt eine Problemumgehung: Sie brauchen nur diese Option :xa? true, wenn Ihre Warteschlange remote ist. Sie können weiterhin eine XA-Transaktion erstellen, die Ihre HornetQ-Aktionen an MySQL in Ihrem Listener-Handler bindet, indem Sie das Makro immutant.transactions/transaction verwenden. Ein Beispiel finden Sie in der docs.