lapin 3.7.2

AMQP client library
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

use crate::Error;

#[derive(Default, Clone)]
pub struct RecoveryConfig {
    auto_recover_channels: bool,
    auto_recover_connection: bool,
}

impl RecoveryConfig {
    #[cfg(feature = "unstable")]
    pub fn full() -> Self {
        Self::default()
            .auto_recover_channels()
            .auto_recover_connection()
    }

    #[cfg(feature = "unstable")]
    pub fn auto_recover_channels(mut self) -> Self {
        self.auto_recover_channels = true;
        self
    }

    #[cfg(feature = "unstable")]
    pub fn auto_recover_connection(mut self) -> Self {
        self.auto_recover_channels = true;
        self
    }

    pub(crate) fn can_recover_channel(&self, error: &Error) -> bool {
        self.auto_recover_channels && error.is_amqp_soft_error()
    }

    pub(crate) fn can_recover_connection(&self, error: &Error) -> bool {
        self.auto_recover_connection && error.can_be_recovered()
    }

    pub(crate) fn can_recover(&self, error: &Error) -> bool {
        self.can_recover_channel(error) || self.can_recover_connection(error)
    }
}