mqi 0.3.0

Idiomatic IBM® MQ Interface (MQI) and MQ Administration Interface (MQAI) APIs
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52

#![allow(dead_code)]

#[cfg(feature = "link")]
#[must_use]
pub const fn mq_library() -> libmqm_sys::link::LinkedMq {
    libmqm_sys::link::LinkedMq
}

#[cfg(all(feature = "dlopen2", not(feature = "link")))]
#[must_use]
pub fn mq_library() -> std::sync::Arc<dl::DebugContainer> {
    use std::sync::Arc;

    use dlopen2::wrapper::Container;
    use libmqm_sys::dlopen2::LoadMqmExt as _;

    Arc::new(dl::DebugContainer(unsafe {
        Container::load_mqm_default().expect("Loading of default MQM should work")
    }))
}

#[cfg(feature = "dlopen2")]
mod dl {
    use libmqm_sys::dlopen2::MqmContainer;

    use crate::{Library, MqaiLibrary};

    // dlopen2 Container doesn't implement Debug so create a wrapper
    pub struct DebugContainer(pub MqmContainer);

    impl Library for DebugContainer {
        type MQ = <MqmContainer as Library>::MQ;

        fn lib(&self) -> &Self::MQ {
            Library::lib(&self.0)
        }
    }

    impl MqaiLibrary for DebugContainer {
        type MQAI = <MqmContainer as MqaiLibrary>::MQAI;

        fn lib(&self) -> &Self::MQAI {
            MqaiLibrary::lib(&self.0)
        }
    }

    impl std::fmt::Debug for DebugContainer {
        fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
            f.write_str("MqmContainer")
        }
    }
}