'BlockingConnection Connection.Blocked timeout'

def test(self):

    url = (DEFAULT_URL + '&blocked_connection_timeout=0.001')
    conn = self._connect(url=url)
    conn._impl._on_connection_blocked(pika.frame.Method(0, pika.spec.Connection.Blocked('TestBlockedConnectionTimeout')))
    with self.assertRaises(pika.exceptions.ConnectionClosed) as excCtx:
        while True:
            conn.process_data_events(time_limit=1)
    self.assertEqual(excCtx.exception.args, (pika.connection.InternalCloseReasons.BLOCKED_CONNECTION_TIMEOUT, 'Blocked    connection    timeout    expired'))
