Merge pull request #105 from featheredtoast/rabbitmq-close-exceptions

rabbitmq try/catch on close
danielsz · Feb 17, 2017 · 7b7b6a1 · 7b7b6a1
2 parents c6ea80d + 77c3e9a
commit 7b7b6a1
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/system/components/rabbitmq.clj b/src/system/components/rabbitmq.clj
@@ -11,8 +11,10 @@
           ch   (lch/open conn)]
       (assoc component :conn conn :ch ch)))
   (stop [component]
-    (rmq/close ch)
-    (rmq/close conn)
+    (try (rmq/close ch)
+         (catch com.rabbitmq.client.AlreadyClosedException e nil))
+    (try (rmq/close conn)
+         (catch com.rabbitmq.client.AlreadyClosedException e nil))
     component))
 
 (defn new-rabbit-mq [uri]