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

Use Exchange defined in rabbit_config in new_jobs rmq agent

parent f4f9ec08
No related branches found
No related tags found
2 merge requests!147Merge previous default branch feat-cod-rmq into main,!119Feat account management
Hide whitespace changes
Inline Side-by-side
prod_rmq_agents/new_jobs.py
+ 1
− 1
View file @ daae1f96
......@@ -14,7 +14,7 @@ args = rc_util.get_args()
logger = rc_util.get_logger(args)
# Instantiate rabbitmq object
rc_rmq = RCRMQ({"exchange": "RegUsr", "exchange_type": "topic"})
rc_rmq = RCRMQ({"exchange": rcfg.Exchange, "exchange_type": "topic"})
def new_jobs(ch, method, properties, body):
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment