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

use std::{collections::VecDeque, iter};

use super::option;
use crate::{Connection, Object, connection::AsConnection, prelude::*, result::ResultComp, types};

impl<C: AsConnection> Object<C> {
    /// This function uses the [`MQINQ`](libmqm_sys::MQINQ) MQ API function.
    pub fn inquire<'a>(&self, selectors: impl IntoIterator<Item = &'a option::AttributeType>) -> ResultComp<option::MultiItem> {
        let mut text_total = 0;
        let mut int_count = 0;
        let mut text_len = Vec::new();

        let select: VecDeque<_> = selectors.into_iter().collect();
        let mut selectors = Vec::with_capacity(select.len());
        for &option::AttributeType {
            attribute,
            text_len: len,
        } in select
        {
            if attribute.is_text() {
                text_total += len;
                text_len.push(len);
            } else if attribute.is_int() {
                int_count += 1;
            }
            selectors.push(attribute);
        }
        let mut output = option::MultiItem {
            selectors,
            int_attr: Vec::with_capacity(int_count),
            text_attr: Vec::with_capacity(text_total as usize),
            text_len,
        };

        let Connection { mq, handle, .. } = self.connection.as_connection();
        mq.mqinq(
            *handle,
            self.handle(),
            &output.selectors,
            &mut output.int_attr.spare_capacity_mut()[..int_count],
            &mut output.text_attr.spare_capacity_mut()[..text_total as usize],
        )
        .map_completion(|()| {
            unsafe {
                output.text_attr.set_len(text_total as usize);
                output.int_attr.set_len(int_count);
            };
            output
        })
    }

    /// This function uses the [`MQINQ`](libmqm_sys::MQINQ) MQ API function.
    pub fn inquire_item(&self, selector: option::AttributeType) -> ResultComp<Option<option::InqResItem<Vec<types::MQCHAR>>>> {
        self.inquire(iter::once(&selector))
            .map_completion(option::MultiItem::into_first)
    }

    /// This function uses the [`MQSET`](libmqm_sys::MQSET) MQ API function.
    pub fn set(&self, items: &impl option::SetItems) -> ResultComp<()> {
        let Connection { mq, handle, .. } = self.connection.as_connection();
        mq.mqset(*handle, self.handle(), items.selectors(), items.int_attr(), items.text_attr())
    }
}