不変リスナーのXAコンテキスト

Question

私はHornetQとmysqlの間でトランザクションを管理するためにimmutantを使用しようとしています。ドキュメントを理解しているので、これを行うには、アプリケーションサーバー内ではなくスタンドアロンのアプリケーションを実行しているため、XAトランザクションを使用する必要があります。

しかし私が試して設定したとき：xa？私のアプリケーションのコンテキストでは、リスナーをセットアップするときに例外が発生します。

(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})) 

「java.lang.IllegalStateException：XAコンテキストから子コンテキストを作成できません。」 （msg/listen）呼び出しから取得します。私は間違って何をしていますか？

Answer 1

あなたはbugを発見したと思いますが、あなたのケースでは、回避策があると思います。キューがリモートの場合は:xa? trueオプションが必要です。 immutant.transactions/transactionマクロを使用して、HornetQアクションをリスナーハンドラ内のMySQLにバインドするXAトランザクションを作成することはできます。例については、docsを参照してください。