amqp_api_shared/
amqp_queue_consumer.rs

1use crate::amqp_consume::AmqpConsume;
2use crate::amqp_qos::AmqpQos;
3use crate::amqp_queue::AmqpQueue;
4use lapin::options::{BasicAckOptions, BasicRejectOptions};
5use serde::{Deserialize, Serialize};
6
7#[derive(Deserialize, Serialize, Clone)]
8pub struct AmqpQueueConsumer {
9    queue: AmqpQueue,
10    qos: AmqpQos,
11    consume: AmqpConsume,
12    acknowledge: BasicAckOptions,
13    reject: BasicRejectOptions,
14}
15
16impl AmqpQueueConsumer {
17    pub fn queue(&self) -> &AmqpQueue {
18        &self.queue
19    }
20
21    pub fn qos(&self) -> &AmqpQos {
22        &self.qos
23    }
24
25    pub fn consume(&self) -> &AmqpConsume {
26        &self.consume
27    }
28
29    pub fn acknowledge(&self) -> &BasicAckOptions {
30        &self.acknowledge
31    }
32
33    pub fn reject(&self) -> &BasicRejectOptions {
34        &self.reject
35    }
36}