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

Fixes bug in producer pool handling

This commit is contained in:
Ask Solem 2011-10-27 21:26:59 +01:00
parent 6e7e591eaa
commit 156da0805d
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
kombu/pools.py
View File

@ -35,7 +35,8 @@ class ProducerPool(Resource):
return Producer(connection)
def create_producer(self):
return self.Producer(self.connections.acquire(block=True))
connection = self.connections.acquire(block=True)
return self.Producer(connection)
def new(self):
return lambda: self.create_producer()
@ -48,8 +49,9 @@ class ProducerPool(Resource):
def prepare(self, p):
if callable(p):
p = p()
p.connection = self.connections.acquire(block=True)
p.revive(p.connection.default_channel)
if not p.channel:
p.connection = self.connections.acquire(block=True)
p.revive(p.connection.default_channel)
return p
def release(self, resource):