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
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75

//! Error types for the client

use fe2o3_amqp::link::ReceiverAttachError;
use fe2o3_amqp_management::error::AttachError;

use crate::{
    amqp::error::{CbsAuthError, OpenReceiverError},
    primitives::error::ClientDisposedError,
    util::IntoAzureCoreError,
};

/// Session ID from the serivce is not set
#[derive(Debug)]
pub struct SessionIdNotSet;

impl std::fmt::Display for SessionIdNotSet {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        write!(f, "Session ID from the serivce is not set")
    }
}

impl std::error::Error for SessionIdNotSet {}

impl From<SessionIdNotSet> for azure_core::Error {
    fn from(value: SessionIdNotSet) -> Self {
        azure_core::Error::new(azure_core::error::ErrorKind::Other, value)
    }
}

/// Error with accepting next session
#[derive(Debug, thiserror::Error)]
pub(crate) enum AcceptNextSessionError {
    /// The connection scope is disposed
    #[error("The connection scope is disposed")]
    ConnectionScopeDisposed,

    /// Error with management link attach
    #[error(transparent)]
    ManagementLinkAttach(#[from] AttachError),

    /// Error with receiver attach
    #[error(transparent)]
    ReceiverAttach(#[from] ReceiverAttachError),

    /// Error with CBS auth
    #[error(transparent)]
    CbsAuth(#[from] CbsAuthError),

    /// Session ID from the service is not set
    #[error("Session ID from the serivce is not set")]
    SessionIdNotSet,
}

impl From<AcceptNextSessionError> for azure_core::Error {
    fn from(value: AcceptNextSessionError) -> Self {
        match value {
            AcceptNextSessionError::ConnectionScopeDisposed => ClientDisposedError.into(),
            AcceptNextSessionError::ManagementLinkAttach(error) => error.into_azure_core_error(),
            AcceptNextSessionError::ReceiverAttach(error) => error.into_azure_core_error(),
            AcceptNextSessionError::CbsAuth(error) => error.into(),
            AcceptNextSessionError::SessionIdNotSet => SessionIdNotSet.into(),
        }
    }
}

impl From<OpenReceiverError> for AcceptNextSessionError {
    fn from(error: OpenReceiverError) -> Self {
        match error {
            OpenReceiverError::ConnectionScopeDisposed => Self::ConnectionScopeDisposed,
            OpenReceiverError::ManagementLinkAttach(error) => Self::ManagementLinkAttach(error),
            OpenReceiverError::ReceiverAttach(error) => Self::ReceiverAttach(error),
            OpenReceiverError::CbsAuth(error) => Self::CbsAuth(error),
        }
    }
}