Skip to content
Snippets Groups Projects
Commit ab0d97c1 authored by Eesaan Atluri's avatar Eesaan Atluri
Browse files

Use fucntions from rc_rmq

parent a79e09cd
No related branches found
No related tags found
2 merge requests!147Merge previous default branch feat-cod-rmq into main,!119Feat account management
...@@ -69,7 +69,7 @@ else: ...@@ -69,7 +69,7 @@ else:
def timeout_handler(signum, frame): def timeout_handler(signum, frame):
print("Process timeout, there's some issue with agents") print("Process timeout, there's some issue with agents")
rc_util.rc_rmq.stop_consume() rc_rmq.stop_consume()
def callback(channel, method, properties, body): def callback(channel, method, properties, body):
...@@ -85,9 +85,8 @@ def callback(channel, method, properties, body): ...@@ -85,9 +85,8 @@ def callback(channel, method, properties, body):
for err in errmsg: for err in errmsg:
print(err) print(err)
rc_util.rc_rmq.stop_consume() rc_rmq.stop_consume()
rc_util.rc_rmq.disconnect() rc_rmq.disconnect()
print(f"{action} action for {args.username} requested.") print(f"{action} action for {args.username} requested.")
......
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