diff options
| author | Ask Solem <ask@celeryproject.org> | 2011-09-26 12:38:34 +0100 |
|---|---|---|
| committer | Ask Solem <ask@celeryproject.org> | 2011-09-26 12:38:34 +0100 |
| commit | 3d3d3a46847c2f85461d44e7a00deec6f0d885d2 (patch) | |
| tree | 95b4ad0df54e5a27e52788297d504d48bb04ceb6 /kombu/pools.py | |
| parent | 56f609db6a2b0317e896613f21a3124f79e63242 (diff) | |
| download | kombu-3d3d3a46847c2f85461d44e7a00deec6f0d885d2.tar.gz | |
Recent changes broke the ProducerPool
Diffstat (limited to 'kombu/pools.py')
| -rw-r--r-- | kombu/pools.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/kombu/pools.py b/kombu/pools.py index 4d0f6eba..1d428b89 100644 --- a/kombu/pools.py +++ b/kombu/pools.py @@ -48,13 +48,13 @@ class ProducerPool(Resource): def prepare(self, p): if callable(p): p = p() - if not p.channel: - p.revive(self.connections.acquire(block=True)) + p.connection = self.connections.acquire(block=True) + p.revive(p.connection.default_channel) return p def release(self, resource): resource.connection.release() - resource.channel = None + resource.connection = resource.channel = None super(ProducerPool, self).release(resource) |