func()

in topic_manager.go [69:83]


func (p *MNSTopicManager) SetTopicAttributes(topicName string, maxMessageSize int32, loggingEnabled bool) (err error) {
	topicName = strings.TrimSpace(topicName)

	if err = checkTopicName(topicName); err != nil {
		return
	}

	message := CreateTopicRequest{
		MaxMessageSize: maxMessageSize,
		LoggingEnabled: loggingEnabled,
	}

	_, err = send(p.cli, p.decoder, PUT, nil, &message, fmt.Sprintf("topics/%s?metaoverride=true", topicName), nil)
	return
}