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

Added support for queue prefixes in SQS.

This commit is contained in:
Nitzan Miron 2011-12-14 14:52:16 +02:00
parent 52c49f7854
commit 48ca2cd63d
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
kombu/transport/SQS.py
View File

@ -158,6 +158,7 @@ class Channel(virtual.Channel):
def _new_queue(self, queue, **kwargs):
"""Ensures a queue exists in SQS."""
queue = self.queue_name_prefix + queue
try:
return self._queue_cache[queue]
except KeyError:
@ -322,6 +323,10 @@ class Channel(virtual.Channel):
@cached_property
def visibility_timeout(self):
return self.transport_options.get("visibility_timeout")
@cached_property
def queue_name_prefix(self):
return self.transport_options.get("queue_name_prefix", '')
@cached_property
def supports_fanout(self):