Merge pull request #121 from diedpigs/revert-3cce99c7

Revert "Move disconnect to callback"

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}