Merge branch 'fjorgemota/patch-1'

2014-01-13 17:09:48 +00:00 · 2014-01-13 17:09:48 +00:00 · 1fbd45f254
parent 11933461aa 1c89de4129
commit 1fbd45f254
1 changed files with 3 additions and 1 deletions
--- a/kombu/simple.py
+++ b/kombu/simple.py
@ -114,12 +114,14 @@ class SimpleQueue(SimpleBase):
        if not isinstance(queue, entity.Queue):
            exchange = entity.Exchange(name, **exchange_opts)
            queue = entity.Queue(name, exchange, name, **queue_opts)
+            routing_key = name
        else:
            name = queue.name
            exchange = queue.exchange
+            routing_key = queue.routing_key
        producer = messaging.Producer(channel, exchange,
                                      serializer=serializer,
-                                      routing_key=name,
+                                      routing_key=routing_key,
                                      compression=compression)
        consumer = messaging.Consumer(channel, queue)
        super(SimpleQueue, self).__init__(channel, producer,