Skip to main content

amqp_client_rust/domain/
integration_event.rs

1#[derive(Debug, Clone)]
2pub struct IntegrationEvent {
3    pub routing_key: String,
4    _exchange_name: String,
5}
6
7impl IntegrationEvent {
8    pub fn new(routing_key: &str, exchange_name: &str) -> Self {
9        Self {
10            routing_key: routing_key.to_string(),
11            _exchange_name: exchange_name.to_string(),
12        }
13    }
14    pub fn event_type(&self) -> String {
15        self._exchange_name.to_string()
16    }
17}