Move disconnect to callback

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}