Commit 4bf72ed0 by larosa

add param

parent 1766d98b
Showing with 1 additions and 1 deletions
......@@ -24,7 +24,7 @@ def listen_from_mq():
credentials=credentials))
channel = conn.channel()
channel.queue_declare(queue=config.rabbit_mq_queue_consumer, durable=True)
channel.basic_consume(config.rabbit_mq_queue_consumer, callback)
channel.basic_consume(queue=config.rabbit_mq_queue_consumer, on_message_callback=callback)
channel.start_consuming()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment