def METHOD_NAME(self):
    self.T.Connection = Mock(name='Connection')
    self.T.client.ssl = False
    self.T.client.port = None
    self.T.client.transport_options = {}
    conn = self.T.establish_connection()
    assert self.T.client.port == self.T.default_connection_params['port']
    assert conn.client == self.T.client
    assert self.T.client.drain_events == conn.drain_events