func()

in topic_manager.go [46:67]

• 17 lines of code
• 3 McCabe index (conditional complexity)

func (p *MNSTopicManager) CreateTopic(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,
	}

	var code int
	code, err = send(p.cli, p.decoder, PUT, nil, &message, "topics/"+topicName, nil)

	if code == http.StatusNoContent {
		err = ERR_MNS_TOPIC_ALREADY_EXIST_AND_HAVE_SAME_ATTR.New(errors.Params{"name": topicName})
		return
	}

	return
}