blob: 38b2b61d10c8083a93aaf344bdabae1671792cfa (
plain)
1
2
3
4
5
6
7
8
9
10
|
from __future__ import annotations
from kombu import Connection
with Connection('amqp://guest:guest@localhost:5672//') as conn:
simple_queue = conn.SimpleQueue('simple_queue')
message = simple_queue.get(block=True, timeout=1)
print(f'Received: {message.payload}')
message.ack()
simple_queue.close()
|
