Не удается подключиться к очереди с обменом сообщениями Immutant

Question

В настоящее время у меня запущен экземпляр ActiveMQ, к которому я пытаюсь подключиться, используя immutant. В настоящее время код для этого подключения выглядит так;

(defn make-ctx
  []
  (log/debug "making context")
  (let [ctx (m/context :host (:host immutant-host) :port (:port immutant-host))]
    (log/debug "context created")
    ctx))

(defn make-listener
  [ctx]
  (let [listener (m/listen topic #(log/debug %) :context ctx)]
    (log/debug "listener created")
    listener))

(defn immutant-test
  []
  (log/debug "testing immutant messaging with ActiveMQ")
  (let [ctx (make-ctx)
        listener (make-listener ctx)]
  (Thread/sleep 15000)
  (.close listener)))

Хотя мой код не делает его переданным функции make-ctx. Когда он пытается создать контекст, я получаю ошибку

Exception in thread "main" java.lang.RuntimeException: javax.jms.JMSException: Failed to create session factory
    at org.projectodd.wunderboss.messaging.jms.DestinationUtil.mightThrow(DestinationUtil.java:47)
    at org.projectodd.wunderboss.messaging.jms.JMSMessagingSkeleton.createContext(JMSMessagingSkeleton.java:64)
    at org.projectodd.wunderboss.messaging.jms.JMSMessagingSkeleton.createContext(JMSMessagingSkeleton.java:181)
    at immutant.messaging$context.doInvoke(messaging.clj:84)
    at clojure.lang.RestFn.invoke(RestFn.java:457)
    at jms_test.core$make_ctx.invoke(core.clj:24)
    at jms_test.core$immutant_test.invoke(core.clj:37)
    at jms_test.core$_main.invoke(core.clj:158)
    at clojure.lang.AFn.applyToHelper(AFn.java:152)
    at clojure.lang.AFn.applyTo(AFn.java:144)
    at jms_test.core.main(Unknown Source)
Caused by: javax.jms.JMSException: Failed to create session factory
    at org.hornetq.jms.client.HornetQConnectionFactory.createConnectionInternal(HornetQConnectionFactory.java:673)
    at org.hornetq.jms.client.HornetQConnectionFactory.createConnection(HornetQConnectionFactory.java:112)
    at org.hornetq.jms.client.HornetQConnectionFactory.createConnection(HornetQConnectionFactory.java:107)
    at org.projectodd.wunderboss.messaging.jms.JMSMessagingSkeleton$1.call(JMSMessagingSkeleton.java:73)
    at org.projectodd.wunderboss.messaging.jms.DestinationUtil.mightThrow(DestinationUtil.java:45)
    ... 10 more
Caused by: HornetQConnectionTimedOutException[errorType=CONNECTION_TIMEDOUT message=HQ119013: Timed out waiting to receive cluster topology. Group:null]
    at org.hornetq.core.client.impl.ServerLocatorImpl.createSessionFactory(ServerLocatorImpl.java:946)
    at org.hornetq.jms.client.HornetQConnectionFactory.createConnectionInternal(HornetQConnectionFactory.java:669)
    ... 14 more

Имутант-хозяин определяется как

(def immutant-host {:host "127.0.0.1" :port 61616})

Мне удалось подключиться к моему брокеру с помощью библиотеки clamq, и я могу отправлять и получать сообщения с этим. Хотя из-за того, что остальная часть приложения построена на немутантных сообщениях, я бы хотел придерживаться этой библиотеки, если это возможно, чтобы не поддерживать несколько библиотек сообщений.

Answer 1

Immutant построен поверх HornetQ, поэтому по умолчанию может подключаться только к серверам HornetQ. Это связано с тем, что спецификация JMS не предоставляет проводной протокол, поэтому каждая реализация имеет свою собственную. Однако, если в действительности удаленный ActiveMQ - это Artemis, вы можете использовать wunderboss-artemis, чтобы разрешить использовать его из Immutant (обратите внимание, что в статье говорится, что вы должны использовать инкрементную сборку Immutant - это больше не так, вы можете использовать Immutant 2.1.0).

Если это не Артемида, это не будет слишком сложно реализовать wunderboss-activemq Адаптер, используя версию Artemis в качестве руководства.