Skip to content

Commit b0709cc

Browse files
authored
Fixed missing async for function on
1 parent 99a90e4 commit b0709cc

File tree

1 file changed

+1
-1
lines changed
  • docs/source/rabbitmq-tutorial/examples/2-work-queues

1 file changed

+1
-1
lines changed

docs/source/rabbitmq-tutorial/examples/2-work-queues/worker.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
loop = asyncio.get_event_loop()
55

66

7-
def on_message(message: IncomingMessage):
7+
async def on_message(message: IncomingMessage):
88
async with message.process():
99
print(" [x] Received message %r" % message)
1010
print(" Message body is: %r" % message.body)

0 commit comments

Comments
 (0)