Rooba
/
kombu
mirror of https://github.com/celery/kombu.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add suppport to custom routing_key if passing a Queue 

I need to use routing keys in my application - to avoid using multiple queues -, but dont want to it be fully asynchronous (eg.: I dont want to use Consumer class directly), so, i made this little modification to the Simple interface: When passing a `kombu.entity.Queue` class, it get the routing key from the Queue and use in the producer, directly.

This avoids the possible issue of, for example, when passing a `kombu.entity.Queue` with a custom Routing Key, the producer starts sending the messages to the wrong routing key, too. =)
This commit is contained in:
Fernando Jorge Mota 2013-12-22 23:51:02 -02:00
parent d48bc0b2a6
commit 1c89de4129
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
kombu/simple.py
View File

@ -114,12 +114,14 @@ class SimpleQueue(SimpleBase):
if not isinstance(queue, entity.Queue): if not isinstance(queue, entity.Queue):
exchange = entity.Exchange(name, **exchange_opts) exchange = entity.Exchange(name, **exchange_opts)
queue = entity.Queue(name, exchange, name, **queue_opts) queue = entity.Queue(name, exchange, name, **queue_opts)
routing_key = name
else: else:
name = queue.name name = queue.name
exchange = queue.exchange exchange = queue.exchange
routing_key = queue.routing_key
producer = messaging.Producer(channel, exchange, producer = messaging.Producer(channel, exchange,
serializer=serializer, serializer=serializer,
routing_key=name, routing_key=routing_key,
compression=compression) compression=compression)
consumer = messaging.Consumer(channel, queue) consumer = messaging.Consumer(channel, queue)
super(SimpleQueue, self).__init__(channel, producer, super(SimpleQueue, self).__init__(channel, producer,