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

#![cfg(feature = "mock")]

use std::thread;

use libmqm_sys::mock::MockMq;
use mqi::{
    Properties, connection, constants,
    prelude::*,
    test::mock,
    types::{FORMAT_NONE, MQCMHO, MQSMPO, MessageId, QueueName},
};

#[test]
fn thread() {
    const QUEUE: QueueName = QueueName(mqstr!("DEV.QUEUE.1"));

    let mut mock = MockMq::new();
    mock::connx_outcome(&mut mock, 0x0d0d, constants::MQCC_OK, constants::MQRC_NONE);
    mock::disc_outcome(&mut mock, constants::MQCC_OK, constants::MQRC_NONE);

    let mut seq = mockall::Sequence::new();
    mock::properties_ok(&mut mock, 0xf0f0, 1, &mut seq);
    mock.expect_MQSETMP().returning(|_, _, _, _, _, _, _, _, cc, rc| {
        // TODO: assert values set
        mock::mqi_outcome_ok(cc, rc);
    });
    mock.expect_MQPUT1().returning(|_, _, _, _, _, _, cc, rc| {
        // TODO: assert values set
        mock::mqi_outcome_ok(cc, rc);
    });

    let (qm, (tag, id)) =
        mqi::connect_lib_with::<(connection::ConnTag, connection::ConnectionId), connection::ThreadNoBlock, _>(mock, &())
            .discard_warning() // ignore warning
            .expect("connection should be established");
    println!("Connection ID: {id}");
    println!("{:?}", tag.0);
    thread::spawn(move || {
        let msg = Properties::new(&qm, MQCMHO::default()).expect("message created");
        msg.set_property("wally", "test", MQSMPO::default())
            .warn_as_error()
            .expect("property set should not fail");

        let msgid: MessageId = qm
            .put_message_with(&QUEUE, &(), &("Hello", FORMAT_NONE))
            .warn_as_error()
            .expect("message put should not fail");
        println!("Message ID: {msgid}");
    })
    .join()
    .expect("thread join should not fail");
}