amqp_api_shared/
amqp_publish.rs

1use lapin::options::BasicPublishOptions;
2use lapin::protocol::basic::AMQPProperties;
3use serde::{Deserialize, Serialize};
4
5#[derive(Deserialize, Serialize, Clone)]
6pub struct AmqpPublish {
7    exchange: String,
8    options: BasicPublishOptions,
9    properties: AMQPProperties,
10}
11
12impl AmqpPublish {
13    pub fn exchange(&self) -> &str {
14        &self.exchange
15    }
16
17    pub fn options(&self) -> &BasicPublishOptions {
18        &self.options
19    }
20
21    pub fn properties(&self) -> &AMQPProperties {
22        &self.properties
23    }
24}