code: func (cli *Client) handleMessage(topicName, message []byte) {
  	// Get the string of the Topic Name.
  	topicNameStr := string(topicName)
  
  	for topicFilter, handler := range cli.conn.ackedSubs {
  		if handler == nil || !match(topicNameStr, topicFilter) {
  			continue
  		}
  
  		// Execute the handler.
  		go handler(topicName, message)
  	}
  }
docs: // handleMessage handles the Application Message.