diff --git a/rc_util.py b/rc_util.py index 5bd5a9745f336008ebe91657220f9393398d5645..9becf2f93878e982d3cb89ff2ccb355a8a28e8c3 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}