Fixes typo in simple_task_queue example

2012-10-12 15:34:24 +01:00 · 2012-10-12 15:34:24 +01:00 · 7b5551f179
parent 557f0da06d
commit 7b5551f179
1 changed files with 1 additions and 0 deletions
--- a/examples/simple_task_queue/client.py
+++ b/examples/simple_task_queue/client.py
@ -18,6 +18,7 @@ def send_as_task(connection, fun, args=(), kwargs={}, priority='mid'):
        maybe_declare(task_exchange, producer.channel)
        producer.publish(payload, serializer='pickle',
                                  compression='bzip2',
+                                  exchange=task_exchange,
                                  routing_key=routing_key)

 if __name__ == '__main__':