Skip to content
Snippets Groups Projects
Unverified Commit d459bcd2 authored by Bo-Chun Chen's avatar Bo-Chun Chen Committed by GitHub
Browse files

Check connection before disconnect (#115)

parent 9296aed0
No related branches found
No related tags found
1 merge request!147Merge previous default branch feat-cod-rmq into main
......@@ -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)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment