XA контекст для неумолимого слушателя

Question

Я пытаюсь использовать immutant для управления транзакциями через HornetQ и mysql. Поскольку я понимаю документы, для этого я должен использовать транзакции 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, если ваша очередь удалена. Вы все равно можете создать транзакцию XA, связывающую ваши действия HornetQ с MySQL в вашем обработчике прослушивателя, используя макрос immutant.transactions/transaction. См. Пример docs.