func SendNormalMessage()

in golang/utils/ClientUtils.go [195:212]

• 16 lines of code
• 4 McCabe index (conditional complexity)

func SendNormalMessage(producer rmq_client.Producer, topic string, body string, tag string, sendNum int, keys ...string) *SendMsgsCollector {
	sendMsgCollector := NewSendMsgsCollector()
	for i := 0; i < sendNum; i++ {
		// new a message
		msg := BuildNormalMessage(topic, body, tag, keys...)
		// send message in sync
		resp, err := producer.Send(context.TODO(), msg)
		if err != nil {
			log.Fatal(err)
		}
		for i := 0; i < len(resp); i++ {
			sendMsgCollector.MsgIds = append(sendMsgCollector.MsgIds, resp[i].MessageID)
			sendMsgCollector.SendMsgs = append(sendMsgCollector.SendMsgs, msg)
			fmt.Printf("%#v\n", resp[i])
		}
	}
	return sendMsgCollector
}