From 5568a6b73cc40e2388b43ffc2cc0120c7030a1d0 Mon Sep 17 00:00:00 2001 From: Ask Solem Date: Sat, 10 Sep 2011 12:03:22 +0100 Subject: [PATCH] Forgot to inherit from PoolGroup --- kombu/pools.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kombu/pools.py b/kombu/pools.py index 72c03335..34ab9b91 100644 --- a/kombu/pools.py +++ b/kombu/pools.py @@ -89,7 +89,7 @@ class Connections(PoolGroup): connections = register_group(Connections()) -class Producers(HashingDict): +class Producers(PoolGroup): def create(self, connection, limit): return ProducerPool(connections[connection], limit=limit)