diff --git a/rc_util.py b/rc_util.py index 3e85e28193155d8d65d0f016338945e0d9ee3cd3..5bd7627a92cff4734b073f8d18621f0e140efee1 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}