From d459bcd21a8cd2d9f9f9ef6dbd6b19ca270740ab Mon Sep 17 00:00:00 2001 From: diedpigs <louistw@uab.edu> Date: Mon, 18 Apr 2022 22:13:40 -0500 Subject: [PATCH] Check connection before disconnect (#115) --- rc_rmq.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/rc_rmq.py b/rc_rmq.py index 16751f1..8227982 100644 --- a/rc_rmq.py +++ b/rc_rmq.py @@ -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) -- GitLab