add server

server.py

@@ -25,7 +25,8 @@ def listen_from_mq():
     channel = conn.channel()
     channel.queue_declare(queue=config.rabbit_mq_queue_consumer, durable=True)
     # 注意 py3.8 的api 和 python3.6的api 是有区别的
-    channel.basic_consume(callback, queue=config.rabbit_mq_queue_consumer)
+    # channel.basic_consume(callback, queue=config.rabbit_mq_queue_consumer)
+    channel.basic_consume(queue=config.rabbit_mq_queue_consumer, on_message_callback=callback)
     channel.start_consuming()