amqp_api_shared/
amqp_consume.rs

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