code: def publish(self, message):
          
          message_data = self._to_data(message)
          self._encode_invoke(topic_publish_codec, message=message_data)
docs: Publishes the message to all subscribers of this topic
  
          :param message: (object), the message to be published.