diff options
| author | Ask Solem <ask@celeryproject.org> | 2014-06-11 14:55:11 +0100 |
|---|---|---|
| committer | Ask Solem <ask@celeryproject.org> | 2014-06-11 14:55:11 +0100 |
| commit | 6524bd293ab580eaa1ac239de38e99856d07c282 (patch) | |
| tree | df953960f43fed46472469473df82620c4786269 /examples/experimental/async_consume.py | |
| parent | e6a3e7eaf233937efe967faa56aab8e6c5b059dd (diff) | |
| parent | 244b882e0c103b915e98de6ebb7d0cb026974515 (diff) | |
| download | kombu-curlclient.tar.gz | |
Merge branch 'master' into curlclientcurlclient
Conflicts:
kombu/async/hub.py
kombu/tests/case.py
kombu/tests/transport/test_redis.py
kombu/transport/SQS.py
Diffstat (limited to 'examples/experimental/async_consume.py')
| -rw-r--r-- | examples/experimental/async_consume.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/examples/experimental/async_consume.py b/examples/experimental/async_consume.py index 1127128a..1a15c7a9 100644 --- a/examples/experimental/async_consume.py +++ b/examples/experimental/async_consume.py @@ -2,12 +2,12 @@ from kombu import Connection, Exchange, Queue, Producer, Consumer from kombu.async import Hub -from threading import Event hub = Hub() exchange = Exchange('asynt') queue = Queue('asynt', exchange, 'asynt') + def send_message(conn): producer = Producer(conn) producer.publish('hello world', exchange=exchange, routing_key='asynt') |