Source

resizer / src / resizer / consumer.clj

Diff from to

File src/resizer/consumer.clj

                                              (println (str "Shutdown listener has fired: " cause))))]
     (try
       (.addShutdownListener channel shutdown-ln)
-      (lhq/declare channel queue :durable true :auto-delete false :exclusive false)
+      (lhq/declare channel queue :durable true :auto-delete false)
       (lhq/bind channel queue exchange)
       (.start (Thread. #(lhcons/subscribe channel queue process-message :auto-ack true) "resize/consumer"))
       (catch IOException ioe ;; see http://www.rabbitmq.com/api-guide.html#shutdown