blob: 71f40f1391b1f85e1d59d2ce4652d3edf92539b0 (
plain)
1
2
3
4
5
6
7
8
9
10
11
|
from __future__ import absolute_import, unicode_literals, print_function
from kombu import Connection # noqa
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: {0}'.format(message.payload))
message.ack()
simple_queue.close()
|
