lapin_async/
configuration.rs

1use parking_lot::RwLock;
2
3use std::sync::Arc;
4
5#[derive(Clone, Debug, Default)]
6#[deprecated(note = "use lapin instead")]
7pub struct Configuration {
8  inner: Arc<RwLock<Inner>>,
9}
10
11impl Configuration {
12  #[deprecated(note = "use lapin instead")]
13  pub fn channel_max(&self) -> u16 {
14    self.inner.read().channel_max
15  }
16
17  pub(crate) fn set_channel_max(&self, channel_max: u16) {
18    self.inner.write().channel_max = channel_max;
19  }
20
21  #[deprecated(note = "use lapin instead")]
22  pub fn frame_max(&self) -> u32 {
23    self.inner.read().frame_max
24  }
25
26  pub(crate) fn set_frame_max(&self, frame_max: u32) {
27    self.inner.write().frame_max = frame_max;
28  }
29
30  #[deprecated(note = "use lapin instead")]
31  pub fn heartbeat(&self) -> u16 {
32    self.inner.read().heartbeat
33  }
34
35  pub(crate) fn set_heartbeat(&self, heartbeat: u16) {
36    self.inner.write().heartbeat = heartbeat;
37  }
38}
39
40#[derive(Debug, Default)]
41struct Inner {
42  channel_max: u16,
43  frame_max:   u32,
44  heartbeat:   u16,
45}
lapin_async/configuration.rs

lapin_async/
configuration.rs
