'Deprecated method used to get a broker connection.
Should be replaced with :meth:`@Celery.connection`
instead, or by acquiring connections from the connection pool:
Examples:
>>> # using the connection pool
>>> with celery.pool.acquire(block=True) as conn:
...     pass
>>> # establish fresh connection
>>> with celery.connection_for_write() as conn:
...     pass'

@classmethod
def establish_connection(cls):

    return cls._get_app().connection_for_write()
