Can someone please look at the below code to see why it is not working. I
am trying to write simple clojure code to send/receive message over
activemq.
I am starting two REPL sessions and loading the same code below in each
session. In one session I invoke the start-consumer function and in the
other session the send-msg function. The REPL running the consumer code
does not get the message.
(ns perf.prg
(:require
[clamq.activemq :as amq]
[clamq.protocol.connection :as connection]
[clamq.protocol.consumer :as consumer]
[clamq.protocol.producer :as producer]))
(def broker-uri "tcp://MDCDSK01BHINDSA:61616")
(def connection (amq/activemq-connection broker-uri))
(def queue-name "producer-consumer-test-queue")
(defn recv-msg [message]
(pprint (str "message received: " message)))
(defn start-consumer [connection]
(let [consumer (connection/consumer connection {:endpoint queue-name
:on-message recv-msg :transacted false})]
(consumer/start consumer)
(Thread/sleep 60000)
(consumer/close consumer)))
(defn send-msg [connection msg]
(let [producer (connection/producer connection)]
(producer/publish producer queue-name msg)))
--
You received this message because you are subscribed to the Google
Groups "Clojure" group.
To post to this group, send email to [email protected]
Note that posts from new members are moderated - please be patient with your
first post.
To unsubscribe from this group, send email to
[email protected]
For more options, visit this group at
http://groups.google.com/group/clojure?hl=en
