examples/hello_consumer.py


1
2
3
4
5
6
7
8

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('Received: %s' % message.payload)
    message.ack()
    simple_queue.close()