amqp_api_shared/
amqp_queue_declare.rs

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