diff options
| author | Ask Solem <ask@celeryproject.org> | 2016-04-06 13:14:05 -0700 |
|---|---|---|
| committer | Ask Solem <ask@celeryproject.org> | 2016-04-06 13:14:05 -0700 |
| commit | b3741774735daa205edd3fbe29e74f8bbec296ee (patch) | |
| tree | 2c0bb51c209c94a6c34afc7ce0381ae580c74563 /examples/experimental | |
| parent | 646ef049b46a9f61748d663edb40a47fe1fc08d4 (diff) | |
| download | kombu-b3741774735daa205edd3fbe29e74f8bbec296ee.tar.gz | |
Use unicode_litereals everywhere and updates flakeplus target to --2.7
Diffstat (limited to 'examples/experimental')
| -rw-r--r-- | examples/experimental/async_consume.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/examples/experimental/async_consume.py b/examples/experimental/async_consume.py index 232292ae..88ec62e4 100644 --- a/examples/experimental/async_consume.py +++ b/examples/experimental/async_consume.py @@ -1,4 +1,5 @@ #!/usr/bin/env python +from __future__ import absolute_import, unicode_literals from kombu import Connection, Exchange, Queue, Producer, Consumer from kombu.async import Hub @@ -11,11 +12,11 @@ queue = Queue('asynt', exchange, 'asynt') def send_message(conn): producer = Producer(conn) producer.publish('hello world', exchange=exchange, routing_key='asynt') - print('MESSAGE SENT') + print('message sent') def on_message(message): - print('RECEIVED: {0!r}'.format(message.body)) + print('received: {0!r}'.format(message.body)) message.ack() hub.stop() # <-- exit after one message |