blob: 5722450e3b1c297d186ecb244de6cc591e749f20 (
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
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()
|
