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
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126

use std::{rc::Rc, sync::Arc};

#[cfg(feature = "link")]
use libmqm_sys::link;
#[cfg(feature = "dlopen2")]
use {dlopen2::wrapper::Container, libmqm_sys::dlopen2::MqWrapper};

/// A set of wrapper functions on the native IBM MQ API's
///
/// The functions provided wrap the native functions in [`Mqi`](libmqm_sys::Mqi) and [`Mqai`](libmqm_sys::Mqai) with additional functionality:
/// * [`MQRC`](crate::types::MQRC) and [`MQCC`](crate::types::MQCC) and return values are returned in a [`ResultComp`](crate::result::ResultComp)
/// * [`Tracing`](::tracing) capabilities
#[derive(Debug, Clone, Copy)]
pub struct MqFunctions<L>(pub L);

/// Holds a reference to an implementation of an MQ library
pub trait Library {
    type MQ;

    fn lib(&self) -> &Self::MQ;
}

#[cfg(feature = "mqai")]
pub trait MqaiLibrary {
    type MQAI: libmqm_sys::Mqai;

    fn lib(&self) -> &Self::MQAI;
}

impl<L: Library> Library for &L {
    type MQ = L::MQ;

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

impl<L: Library> Library for Rc<L> {
    type MQ = L::MQ;

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

impl<L: Library> Library for Arc<L> {
    type MQ = L::MQ;

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

#[cfg(feature = "link")]
impl Library for link::LinkedMq {
    type MQ = Self;

    #[inline]
    fn lib(&self) -> &Self::MQ {
        self
    }
}

#[cfg(feature = "mqai")]
impl<L: MqaiLibrary> MqaiLibrary for &L {
    type MQAI = L::MQAI;

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

#[cfg(feature = "mqai")]
impl<L: MqaiLibrary> MqaiLibrary for Rc<L> {
    type MQAI = L::MQAI;

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

#[cfg(feature = "mqai")]
impl<L: MqaiLibrary> MqaiLibrary for Arc<L> {
    type MQAI = L::MQAI;

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

#[cfg(all(feature = "link", feature = "mqai"))]
impl MqaiLibrary for link::LinkedMq {
    type MQAI = Self;

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

#[cfg(feature = "link")]
impl MqFunctions<link::LinkedMq> {
    /// A compile-time linked [`MqFunctions`]
    #[must_use]
    #[inline]
    pub const fn linked() -> Self {
        Self(link::LinkedMq)
    }
}

#[cfg(feature = "dlopen2")]
impl Library for Container<MqWrapper> {
    type MQ = Self;

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

#[cfg(all(feature = "dlopen2", feature = "mqai"))]
impl MqaiLibrary for Container<MqWrapper> {
    type MQAI = Self;

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