func SendMessageAsync()

in golang/utils/ClientUtils.go [181:193]

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

func SendMessageAsync(producer rmq_client.Producer, message *rmq_client.Message, sendMsgCollector *SendMsgsCollector) {
	// send message in async
	producer.SendAsync(context.TODO(), message, func(ctx context.Context, resp []*rmq_client.SendReceipt, err error) {
		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])
		}
	})
}