summaryrefslogtreecommitdiff
path: root/examples/hello_consumer.py
diff options
context:
space:
mode:
Diffstat (limited to 'examples/hello_consumer.py')
-rw-r--r--examples/hello_consumer.py5
1 files changed, 4 insertions, 1 deletions
diff --git a/examples/hello_consumer.py b/examples/hello_consumer.py
index ebc6d038..5722450e 100644
--- a/examples/hello_consumer.py
+++ b/examples/hello_consumer.py
@@ -1,8 +1,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: %s' % message.payload)
+ print('Received: {0}'.format(message.payload))
message.ack()
simple_queue.close()