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

use libmqm_sys::Mqi;

use super::option::{ExecuteOption, ExecuteParam};
use crate::{
    Connection, Library, MqaiLibrary,
    bag::{Bag, BagDrop, Owned},
    constants,
    prelude::*,
    result::ResultComp,
};

impl<L: MqaiLibrary + Library<MQ: Mqi> + Clone, H> Connection<L, H> {
    pub fn execute<'a>(&self, admin: &Bag<impl BagDrop, L>, options: &impl ExecuteOption<'a>) -> ResultComp<Bag<Owned, L>> {
        let functions = &self.mq;
        let handle = self.handle;
        // There shouldn't be any warnings for creating a bag - so treat the warning as an error
        let response_bag = Bag::new_lib(functions.0.clone(), constants::MQCBO_ADMIN_BAG).warn_as_error()?;

        let mut param = ExecuteParam::default();
        options.apply_param(&mut param);

        functions
            .mq_execute(
                handle,
                param.command,
                param.options,
                admin,
                response_bag.handle(),
                param.admin_object,
                param.reply_object,
            )
            .map_completion(|()| response_bag)
    }
}