Skip to content
Snippets Groups Projects
Commit e05538df authored by Bo-Chun Chen's avatar Bo-Chun Chen
Browse files

Revert "Move disconnect to callback"

This reverts commit 3cce99c7.
parent 246f48c9
No related branches found
No related tags found
2 merge requests!147Merge previous default branch feat-cod-rmq into main,!121Revert "Move disconnect to callback"
......@@ -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}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment