err = b.ch.ExchangeDeclare(
        serviceName, // name
        "direct",    // kind
        true,        // durable
        false,       // autoDelete
        false,       //internal
        false,       // no wait
        nil,         // args
    )

    b.queue, err = b.ch.QueueDeclare(
        serviceName,
        true,  // durable
        false, // autoDelete
        false, // exclusive
        false, // no wait
        nil,   // args
    )

    for _, s := range keys {
            err = b.ch.QueueBind(
            b.queue.Name, // name
            s,            // key
            serviceName,  // Exchange
            false,        // no wait
            nil) // args
    }

    msgs, err := b.ch.Consume(
        b.queue.Name, // queue
        "",           // consumer
        true,         // auto ack
        false,        // exclusive
        false,        // no local
        false,        // no wait
        nil,          // args
    )