func SendMessage()

in golang/utils/ClientUtils.go [169:179]


func SendMessage(producer rmq_client.Producer, message *rmq_client.Message, sendMsgCollector *SendMsgsCollector) {
	resp, err := producer.Send(context.TODO(), message)
	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, message)
		fmt.Printf("%#v\n", resp[i])
	}
}