cp_microservice/impl/api/shared/
amqp_qos.rs

1use lapin::options::BasicQosOptions;
2use serde::{Deserialize, Serialize};
3
4#[derive(Deserialize, Serialize, Clone)]
5pub struct AmqpQos {
6    prefetch_count: u16,
7    options: BasicQosOptions,
8}
9
10impl AmqpQos {
11    pub fn prefetch_count(&self) -> u16 {
12        self.prefetch_count
13    }
14
15    pub fn options(&self) -> &BasicQosOptions {
16        &self.options
17    }
18}