Skip to content
Snippets Groups Projects

Check connection before disconnect in rc_rmq

Merged Bo-Chun Chen requested to merge github/fork/diedpigs/feat-rcrmq-disconnect into feat-cod-rmq
1 file
+ 4
3
Compare changes
  • Side-by-side
  • Inline
+ 4
3
@@ -100,9 +100,10 @@ class RCRMQ(object):
return result.method.queue
def disconnect(self):
self._channel.close()
self._connection.close()
self._connection = None
if self._connection:
self._channel.close()
self._connection.close()
self._connection = None
def delete_queue(self, queue):
self._channel.queue_delete(queue)
Loading