async def METHOD_NAME(self):
    """
    Open the NATS publisher transport by connected to NATS.
    """
    if not self._nats_client.is_connected:
        raise TTransportException(TTransportExceptionType.NOT_OPEN,
                                  'NATS is not connected')