Getting data message from Rabbit MQ then process each data one by one.

GetRabbitMessageThenProcess.go

func GetRabbitMessageThenProcess() {
	defer log.RecoverWithTrace()
	_, ch := rabbit.ConnectMQ()

	_, err := ch.QueueDeclare(
		etc.TranscriptQueue,
		true,
		false,
		false,
		false,
		nil,
	)
	if err != nil {
		log.Error(err)
		return
	}

	messages, err := ch.Consume(
		etc.TranscriptQueue,
		"",
		true,
		false,
		false,
		false,
		nil,
	)
	if err != nil {
		log.Error(err)
		return
	}

	forever := make(chan bool)

	go func(msg <-chan amqp091.Delivery) {
		for m := range msg {
			doProcess(string(m.Body))
		}
	}(messages)

	<-forever
}