amqp_api_server/config/
amqp_input_api.rs

1use amqp_api_shared::amqp_queue_consumer::AmqpQueueConsumer;
2use serde::{Deserialize, Serialize};
3
4#[derive(Deserialize, Serialize, Clone)]
5pub struct AmqpInputApi {
6    id: String,
7    queue_consumer: AmqpQueueConsumer,
8    max_concurrent_requests: u16,
9}
10
11impl AmqpInputApi {
12    pub fn id(&self) -> &str {
13        &self.id
14    }
15
16    pub fn queue_consumer(&self) -> &AmqpQueueConsumer {
17        &self.queue_consumer
18    }
19
20    pub fn max_concurrent_requests(&self) -> u16 {
21        self.max_concurrent_requests
22    }
23}