From e05538df20705895dbd25ea741f63c4d7adc722e Mon Sep 17 00:00:00 2001 From: Bo-Chun Louis Chen <louistw@uab.edu> Date: Thu, 21 Apr 2022 14:49:04 -0500 Subject: [PATCH] Revert "Move disconnect to callback" This reverts commit 3cce99c7f99f739c97e99858a88f59722a1e5134. --- rc_util.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/rc_util.py b/rc_util.py index 5bd5a97..9becf2f 100644 --- a/rc_util.py +++ b/rc_util.py @@ -89,7 +89,8 @@ def worker(ch, method, properties, body): for err in errmsg: print(err) - rc_rmq.disconnect() + rc_rmq.stop_consume() + rc_rmq.delete_queue() def consume( @@ -117,6 +118,7 @@ def consume( "cb": callback, } ) + rc_rmq.disconnect() return {"success": True} -- GitLab