From b0709ccf03ef8a86291c0e2b2d89a69c6bd278af Mon Sep 17 00:00:00 2001 From: Jules Lasne Date: Wed, 6 Oct 2021 11:27:11 +0200 Subject: [PATCH] Fixed missing async for function on --- docs/source/rabbitmq-tutorial/examples/2-work-queues/worker.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/source/rabbitmq-tutorial/examples/2-work-queues/worker.py b/docs/source/rabbitmq-tutorial/examples/2-work-queues/worker.py index e7046480..3603c4d5 100644 --- a/docs/source/rabbitmq-tutorial/examples/2-work-queues/worker.py +++ b/docs/source/rabbitmq-tutorial/examples/2-work-queues/worker.py @@ -4,7 +4,7 @@ loop = asyncio.get_event_loop() -def on_message(message: IncomingMessage): +async def on_message(message: IncomingMessage): async with message.process(): print(" [x] Received message %r" % message) print(" Message body is: %r" % message.body)