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

Made use of exclusive queue

parent 3cce99c7
No related branches found
No related tags found
1 merge request!116Update code regarding rcrmq class change
......@@ -68,5 +68,8 @@ signal.setitimer(signal.ITIMER_REAL, timeout)
print("Waiting for completion...")
rc_util.consume(
queuename, routing_key=f"complete.{queuename}", callback=callback
queuename,
routing_key=f"complete.{queuename}",
exclusive=True,
callback=callback,
)
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