From 3cce99c7f99f739c97e99858a88f59722a1e5134 Mon Sep 17 00:00:00 2001
From: Bo-Chun Louis Chen <louistw@uab.edu>
Date: Wed, 13 Apr 2022 15:33:39 -0500
Subject: [PATCH] Move disconnect to callback
---
rc_util.py | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
diff --git a/rc_util.py b/rc_util.py
index 3e85e28..5bd7627 100644
--- a/rc_util.py
+++ b/rc_util.py
@@ -47,8 +47,7 @@ def worker(ch, method, properties, body):
for err in errmsg:
print(err)
- rc_rmq.stop_consume()
- rc_rmq.delete_queue()
+ rc_rmq.disconnect()
def consume(
@@ -76,7 +75,6 @@ def consume(
"cb": callback,
}
)
- rc_rmq.disconnect()
return {"success": True}
--
GitLab