azeventhubs 0.20.0

An unofficial AMQP 1.0 rust client for Azure Event Hubs
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use std::borrow::Cow;

use fe2o3_amqp_types::messaging::{Message, MessageAnnotations, Properties};

/// The system properties of an AMQP message
#[derive(Debug)]
pub struct AmqpSystemProperties<'a> {
    pub(crate) amqp_properties: Option<Cow<'a, Properties>>,
    pub(crate) amqp_message_annotations: Option<Cow<'a, MessageAnnotations>>,
}

impl<'a, B> From<&'a Message<B>> for AmqpSystemProperties<'a> {
    fn from(message: &'a Message<B>) -> Self {
        Self {
            amqp_properties: message.properties.as_ref().map(Cow::Borrowed),
            amqp_message_annotations: message.message_annotations.as_ref().map(Cow::Borrowed),
        }
    }
}

impl<'a> AmqpSystemProperties<'a> {}