'Establish the broker connection used for consuming tasks.
Retries establishing the connection if the
:setting:`broker_connection_retry` setting is enabled'

def connect(self):

    conn = self.connection_for_read(heartbeat=self.amqheartbeat)
    if self.hub:
        conn.transport.register_with_event_loop(conn.connection, self.hub)
    return conn
