cp_microservice/impl/api/shared/
amqp_queue_rpc_publisher.rs

1use serde::{Deserialize, Serialize};
2
3use crate::r#impl::api::shared::amqp_publish::AmqpPublish;
4use crate::r#impl::api::shared::amqp_queue_consumer::AmqpQueueConsumer;
5
6#[derive(Deserialize, Serialize, Clone)]
7pub struct AmqpQueueRpcPublisher {
8    queue_name: String,
9    publish: AmqpPublish,
10    response: AmqpQueueConsumer,
11}
12
13impl AmqpQueueRpcPublisher {
14    pub fn queue_name(&self) -> &str {
15        self.queue_name.as_str()
16    }
17
18    pub fn publish(&self) -> &AmqpPublish {
19        &self.publish
20    }
21
22    pub fn response(&self) -> &AmqpQueueConsumer {
23        &self.response
24    }
25}