Changes in this commit:

* Create routing key based on 'queuename' rather then 'username'

prod_rmq_agents/dir_verify.py

@@ -55,10 +55,9 @@ def dir_verify(ch, method, properties, body):
         logger.error('', exc_info=True)
 
     # send confirm message
-    rc_rmq.publish_msg({
-        'routing_key': 'confirm.' + username,
-        'msg': msg
-    })
+    rc_rmq.publish_msg(
+        {"routing_key": "confirm." + msg["queuename"], "msg": msg}
+    )
 
     logger.debug(f'User {username} confirmation sent')
 

prod_rmq_agents/get-next-uid-gid.py

@@ -82,12 +82,12 @@ def resolve_uid_gid(ch, method, properties, body):
     ch.basic_ack(delivery_tag=method.delivery_tag)
 
     # Send confirm message
-    logger.debug('rc_rmq.publish_msg()')
-    rc_rmq.publish_msg({
-        'routing_key': 'confirm.' + username,
-        'msg': msg
-    })
-    logger.info('confirmation sent')
+    logger.debug("rc_rmq.publish_msg()")
+    rc_rmq.publish_msg(
+        {"routing_key": "confirm." + msg["queuename"], "msg": msg}
+    )
+    logger.info("confirmation sent")
+
 
 logger.info("Start listening to queue: {}".format(task))
 rc_rmq.start_consume({

prod_rmq_agents/git_commit.py

@@ -80,12 +80,11 @@ def git_commit(ch, method, properties, body):
         logger.error('', exc_info=True)
 
     # Send confirm message
-    logger.debug('rc_rmq.publish_msge()')
-    rc_rmq.publish_msg({
-        'routing_key': 'confirm.' + username,
-        'msg': msg
-    })
-    logger.info('confirmation sent')
+    logger.debug("rc_rmq.publish_msge()")
+    rc_rmq.publish_msg(
+        {"routing_key": "confirm." + msg["queuename"], "msg": msg}
+    )
+    logger.info("confirmation sent")
 
     # Acknowledge message
     logger.debug('ch.basic_ack()')

prod_rmq_agents/notify_user.py

@@ -81,10 +81,9 @@ def notify_user(ch, method, properties, body):
         msg['errmsg'] = errmsg if errmsg else 'Unexpected error'
 
     # Send confirm message
-    rc_rmq.publish_msg({
-        'routing_key': 'confirm.' + username,
-        'msg': msg
-    })
+    rc_rmq.publish_msg(
+        {"routing_key": "confirm." + msg["queuename"], "msg": msg}
+    )
 
     logger.debug(f'User {username} confirmation sent')
 

prod_rmq_agents/subscribe_mail_lists.py

@@ -66,12 +66,12 @@ def mail_list_subscription(ch, method, properties, body):
     ch.basic_ack(delivery_tag=method.delivery_tag)
 
     # send confirm message
-    logger.debug('rc_rmq.publish_msg()')
-    rc_rmq.publish_msg({
-        'routing_key': 'confirm.' + username,
-        'msg': msg
-    })
-    logger.info('confirmation sent')
+    logger.debug("rc_rmq.publish_msg()")
+    rc_rmq.publish_msg(
+        {"routing_key": "confirm." + msg["queuename"], "msg": msg}
+    )
+    logger.info("confirmation sent")
+
 
 logger.info("Start listening to queue: {}".format(task))
 rc_rmq.start_consume({