func ConsumerClient(queueName string) <-chan amqp.Delivery {
	connection := getConnection()
	ch, _ := connection.Channel()

	msgs, _ := ch.Consume(
		queueName, // queue
		"",        // consumer
		true,      // auto-ack
		false,     // exclusive
		false,     // no-local
		false,     // no-wait
		nil,       // args
	)
	return msgs
}