pass in queue name to hornetq-run

hiredman · Oct 4, 2010 · 29197b5 · 29197b5
1 parent a4a164a
commit 29197b5
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 5 deletions.
diff --git a/src/conduit/hornetq.clj b/src/conduit/hornetq.clj
@@ -1,6 +1,7 @@
 ;;TODO: procs can yield multiple values, how to deal with that with
 ;;reply queues?
 ;;TODO: is there some better way to "run procs" on a queue?
+;;TODO: auto serialize
 (ns conduit.hornetq
   (:use [conduit.core])
   (:import (org.hornetq.api.core TransportConfiguration SimpleString)
@@ -139,7 +140,7 @@
 
 (defn hornetq-run
   "start a single thread executing a proc"
-  [{queue :source :as proc} session]
+  [proc queue session]
   (.start session)
   (try
     (create-queue session queue)

diff --git a/test/conduit_hornetq/test/core.clj b/test/conduit_hornetq/test/core.clj
@@ -16,15 +16,19 @@
     (a-arr identity))
    pass-through))
 
+(def upcase-queue (str "some.q." (UUID/randomUUID)))
+
 (def upcase (a-hornetq
-             (str "some.q." (UUID/randomUUID))
+             upcase-queue
              "upcase"
              (a-comp deserialize
                      (a-arr #(.toUpperCase %))
                      serialize)))
 
+(def evaler-queue (str "some.q." (UUID/randomUUID)))
+
 (def evaler (a-hornetq
-             (str "some.q." (UUID/randomUUID))
+             evaler-queue
              "eval"
              (a-comp deserialize
                      (a-arr eval)
@@ -36,12 +40,12 @@
                   (let [session *session*]
                     (future
                       (try
-                        (hornetq-run upcase session)
+                        (hornetq-run upcase upcase-queue session)
                         (catch Exception e
                           (.printStackTrace e))))
                     (future
                       (try
-                        (hornetq-run evaler session)
+                        (hornetq-run evaler evaler-queue session)
                         (catch Exception e
                           (.printStackTrace e)))))
                   (try