username

chip1stop.py

@@ -263,7 +263,7 @@ class DataUtil:
 
 
 class Producer:
 class Producer:
     def __init__(self):
     def __init__(self):
-        credentials = pika.PlainCredentials(username=config["rabbit_mq_host"], password=config["rabbit_mq_password"])
+        credentials = pika.PlainCredentials(username=config["rabbit_mq_user"], password=config["rabbit_mq_password"])
         self.conn = pika.BlockingConnection(pika.ConnectionParameters(
         self.conn = pika.BlockingConnection(pika.ConnectionParameters(
             host=config["rabbit_mq_host"],
             host=config["rabbit_mq_host"],
             port=config["rabbit_mq_port"],
             port=config["rabbit_mq_port"],