diff options
Diffstat (limited to 'kombu/pools.py')
| -rw-r--r-- | kombu/pools.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/kombu/pools.py b/kombu/pools.py index 9db8db8d..065a6ebb 100644 --- a/kombu/pools.py +++ b/kombu/pools.py @@ -105,6 +105,8 @@ class Connections(PoolGroup): def create(self, connection, limit): return connection.Pool(limit=limit) + + connections = register_group(Connections(limit=use_global_limit)) # noqa: E305 @@ -113,6 +115,8 @@ class Producers(PoolGroup): def create(self, connection, limit): return ProducerPool(connections[connection], limit=limit) + + producers = register_group(Producers(limit=use_global_limit)) # noqa: E305 |