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)