pub fn new(

    conn_pool: &Arc<Mutex<HashMap<String, Connection>>>,

    host_uri: &Url,

    persistent: bool,

    handler: Arc<dyn EventHandler>,

) -> Result<Queue, String> {

    let conn = get_connection(&conn_pool, host_uri)?;

    let mut queue = match conn {

        Connection::Amqp(conn, counter) => {

            let opts = QueueOptions::Amqp(

                AmqpQueueOptions {

                    name: QUEUE_NAME.to_string(),

                    is_recv: false,

                    reliable: true,

                    persistent,

                    broadcast: false,

                    ..Default::default()

                },

                &conn,

            );

            {

                *counter.lock().unwrap() += 1;

            }

            Queue::new(opts)?

        Connection::Mqtt(conn, counter) => {

            let opts = QueueOptions::Mqtt(

                MqttQueueOptions {

                    name: QUEUE_NAME.to_string(),

                    is_recv: false,

                    reliable: true,

                    broadcast: false,

                    ..Default::default()

                },

                &conn,

            );

            {

                *counter.lock().unwrap() += 1;

            }

            Queue::new(opts)?

    queue.set_handler(handler);

    if let Err(e) = queue.connect() {

    }

    Ok(queue)

}