func CreateTopic()

in golang/utils/MQAdminUtils.go [39:57]

• 18 lines of code
• 5 McCabe index (conditional complexity)

func CreateTopic(topicName string, brokerAddr string, clusterName string, nameserver string) {
	// use absolute path
	command := "sh " + root + "/rocketmq-admintools/bin/mqadmin updateTopic -t " + topicName
	if nameserver != "" {
		command += " -n " + nameserver
	}
	if brokerAddr != "" {
		command += " -b " + brokerAddr
	}
	if clusterName != "" {
		command += " -c " + clusterName
	}
	fmt.Println(command)
	out, err := exec.Command("/bin/bash", "-c", command).Output()
	if err != nil {
		log.Fatal(err)
	}
	fmt.Println(string(out))
}