'Establish connection used for consuming.
See Also:
:meth:`connection` for supported arguments.'

def connection_for_read(self, url=None, **kwargs):

    return self._connection((url or self.conf.broker_read_url), **kwargs)
