diff --git a/subscribe_mail_lists.py b/subscribe_mail_lists.py index 483e1dd168382bdcfcf4e5580cbf797ae00b4533..49ac1d7e781afeb951e626399aceb2cf43260cab 100644 --- a/subscribe_mail_lists.py +++ b/subscribe_mail_lists.py @@ -72,7 +72,7 @@ def mail_list_subscription(ch, method, properties, body): logger.info("Start listening to queue: {}".format(task)) rc_rmq.start_consume({ 'queue': task, # Define your Queue name - 'routing_key': "create.*", # Define your routing key + 'routing_key': "verify.*", # Define your routing key 'cb': mail_list_subscription # Pass in callback function you just define })