'Broker connection pool: :class:`~@pool`.
Note:
This attribute is not related to the workers concurrency pool.'

@property
def pool(self):

    if (self._pool is None):
        self._ensure_after_fork()
        limit = self.conf.broker_pool_limit
        pools.set_limit(limit)
        self._pool = pools.connections[self.connection_for_write()]
    return self._pool
