async def METHOD_NAME(self, topic: str, data):
    """
    Publish a message to NATS on a given topic.
    Args:
        topic: string
        data: bytearray
    """
    if not self.is_open():
        raise TTransportException(TTransportExceptionType.NOT_OPEN,
                                  'Transport is not connected')
    if self._check_publish_size(data):
        raise TTransportException(
            type=TTransportExceptionType.REQUEST_TOO_LARGE,
            message='Message exceeds max message size'
        )
    await self._nats_client.METHOD_NAME('frugal.{0}'.format(topic), data)