Skip to content
Browse files


  • Loading branch information...
1 parent ea8e2e0 commit cd4ebebfa11f4d9c01783eb3a6a3a39df2ad3947 @michaelklishin michaelklishin committed
Showing with 4 additions and 4 deletions.
  1. +3 −3 src/langohr/consumers.clj
  2. +1 −1  test/langohr/test/basic.clj
6 src/langohr/consumers.clj
@@ -52,11 +52,11 @@
(defn subscribe
"Adds new blocking consumer to a queue using basic.consume AMQP method"
- [^Channel channel, ^String queue, ^clojure.lang.IFn message-handler, & { :keys [consumer-tag, auto-ack, exclusive, no-local, arguments]
- :or { consumer-tag "", auto-ack false, exclusive false, no-local false } }]
+ [^Channel channel ^String queue ^clojure.lang.IFn message-handler & { :keys [consumer-tag auto-ack exclusive no-local arguments]
+ :or { consumer-tag "" auto-ack false exclusive false no-local false } }]
(let [queueing-consumer (QueueingConsumer. channel)]
- (lhb/consume channel queue queueing-consumer :consumer-tag consumer-tag :auto-ack auto-ack :exclusive exclusive, :arguments arguments, :no-local no-local)
+ (lhb/consume channel queue queueing-consumer :consumer-tag consumer-tag :auto-ack auto-ack :exclusive exclusive :arguments arguments :no-local no-local)
(while true
(let [delivery (.nextDelivery queueing-consumer)]
2  test/langohr/test/basic.clj
@@ -36,7 +36,7 @@
latch (java.util.concurrent.CountDownLatch. n)
msg-handler (fn [delivery message-properties message-payload]
(.countDown latch))]
- (.start (Thread. #((lhcons/subscribe channel queue msg-handler :consumer-tag tag, :auto-ack true)) "t-publishing-using-default-exchange-and-default-message-attributes/consumer"))
+ (.start (Thread. #((lhcons/subscribe channel queue msg-handler :consumer-tag tag :auto-ack true)) "t-publishing-using-default-exchange-and-default-message-attributes/consumer"))
(.start (Thread. (fn []
(dotimes [i n]
(lhb/publish channel exchange queue payload :priority 8, :message-id msg-id, :content-type content-type, :headers { "see you soon" "à bientôt" }))) "publisher"))

0 comments on commit cd4ebeb

Please sign in to comment.
Something went wrong with that request. Please try again.