py3.6

server.py

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