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

compat.Publisher now supports passing channel

This commit is contained in:
Ask Solem 2011-08-19 23:59:04 +01:00
parent 83320afa97
commit 3146f3f9db
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
kombu/compat.py
View File

@ -73,11 +73,16 @@ class Publisher(messaging.Producer):
durable = True
auto_delete = False
_closed = False
_provided_channel = None
def __init__(self, connection, exchange=None, routing_key=None,
exchange_type=None, durable=None, auto_delete=None, **kwargs):
exchange_type=None, durable=None, auto_delete=None, channel=None,
**kwargs):
self.connection = connection
self.backend = connection.channel()
if channel:
self._provided_channel = self.backend = channel
else:
self.backend = connection.channel()
self.exchange = exchange or self.exchange
self.exchange_type = exchange_type or self.exchange_type
@ -106,7 +111,8 @@ class Publisher(messaging.Producer):
super(Publisher, self).revive(channel)
def close(self):
self.backend.close()
if not self._provided_channel:
self.backend.close()
self._closed = True
def __enter__(self):