azservicebus 0.25.1

An unofficial AMQP 1.0 rust client for Azure Service Bus
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

use fe2o3_amqp_types::messaging::ApplicationProperties;

use super::management_constants::{properties::SERVER_TIMEOUT, request::ASSOCIATED_LINK_NAME};

pub(crate) mod add_rule;
pub(crate) mod cancel_scheduled_message;
pub(crate) mod enumerate_rules;
pub(crate) mod get_session_state;
pub(crate) mod peek_message;
pub(crate) mod peek_session_message;
pub(crate) mod receive_by_sequence_number;
pub(crate) mod remove_rule;
pub(crate) mod renew_lock;
pub(crate) mod renew_session_lock;
pub(crate) mod schedule_message;
pub(crate) mod set_session_state;
pub(crate) mod update_disposition;

fn encode_application_properties(
    server_timeout: Option<u32>,
    associated_link_name: Option<String>,
) -> Option<ApplicationProperties> {
    let mut props = None;
    if let Some(server_timeout) = server_timeout {
        props
            .get_or_insert(ApplicationProperties::default())
            .insert(SERVER_TIMEOUT.into(), server_timeout.into());
    }
    if let Some(associated_link_name) = associated_link_name {
        props
            .get_or_insert(ApplicationProperties::default())
            .insert(ASSOCIATED_LINK_NAME.into(), associated_link_name.into());
    }
    props
}