async def METHOD_NAME(self):
    self.mock_nats_client.is_connected = False
    with self.assertRaises(TTransportException) as cm:
        await self.pub_trans.open()
    self.assertEqual(TTransportExceptionType.NOT_OPEN, cm.exception.type)