Catch channel closed error on channel close

cropsinsilico · Nov 16, 2017 · 9cba5a7 · 9cba5a7
1 parent f04d7bf
commit 9cba5a7
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/cis_interface/communication/RMQComm.py b/cis_interface/communication/RMQComm.py
@@ -211,7 +211,10 @@ def close_queue(self):
     def close_channel(self):
         r"""Close the channel if it exists."""
         if self.channel:
-            self.channel.close()
+            try:
+                self.channel.close()
+            except pika.exceptions.ChannelClosed:
+                pass
         self.channel = None
 
     def close_connection(self):