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
36
37
38
39
40
41
42

use fe2o3_amqp_management::error::Error as ManagementError;
use fe2o3_amqp_management::response::Response;
use fe2o3_amqp_types::primitives::{Array, OrderedMap};

use crate::amqp::management_constants::properties::SEQUENCE_NUMBERS;

type SequenceNumbers = Array<i64>;
type ScheduleMessageResponseBody = OrderedMap<String, SequenceNumbers>;

pub(crate) struct ScheduleMessageResponse {
    pub sequence_numbers: Vec<i64>,
}

impl ScheduleMessageResponse {
    pub fn into_sequence_numbers(self) -> Vec<i64> {
        self.sequence_numbers
    }
}

impl Response for ScheduleMessageResponse {
    const STATUS_CODE: u16 = 200;

    type Body = Option<ScheduleMessageResponseBody>;

    type Error = ManagementError;

    fn decode_message(
        message: fe2o3_amqp_types::messaging::Message<Self::Body>,
    ) -> Result<Self, Self::Error> {
        let sequence_numbers = message
            .body
            .ok_or(ManagementError::DecodeError(None))?
            .swap_remove(SEQUENCE_NUMBERS)
            .ok_or_else(|| fe2o3_amqp_management::error::InvalidType {
                expected: SEQUENCE_NUMBERS.to_string(),
                actual: "None".to_string(),
            })?
            .into_inner();

        Ok(Self { sequence_numbers })
    }
}