(let [ch (lch/open (...) {queue-name' :queue} (lq/declare ch "" {:exclusive true :auto-delete true}) handler (fn [ch {:keys [routing-key delivery-tag]} ^bytes payload] (throw (RuntimeException. "Some error")))] (lq/bind ch queue-name' "amq.topic" {:routing-key ".........."}) (lc/subscribe ch queue-name' handler {:block true :auto-ack false})))
--
You received this message because you are subscribed to the Google Groups "clojure-rabbitmq" group.
To unsubscribe from this group and stop receiving emails from it, send an email to clojure-rabbitmq+unsubscribe@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
You received this message because you are subscribed to a topic in the Google Groups "clojure-rabbitmq" group.
To unsubscribe from this topic, visit https://groups.google.com/d/topic/clojure-rabbitmq/UjLexUFfdac/unsubscribe.
To unsubscribe from this group and all its topics, send an email to clojure-rabbit...@googlegroups.com.