mirror of https://github.com/celery/kombu.git
Forgot to inherit from PoolGroup
This commit is contained in:
parent
e5e07f0c55
commit
5568a6b73c
|
@ -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)
|
||||
|
|
Loading…
Reference in New Issue