amqp_api_shared/
amqp_request.rs

1use crate::amqp_publish::AmqpPublish;
2use serde::{Deserialize, Serialize};
3
4#[derive(Deserialize, Serialize, Clone)]
5pub struct AmqpRequest {
6    queue_name: String,
7    publish: AmqpPublish,
8}
9
10impl AmqpRequest {
11    pub fn queue_name(&self) -> &str {
12        &self.queue_name
13    }
14
15    pub fn publish(&self) -> &AmqpPublish {
16        &self.publish
17    }
18}