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 }