web_queue_meta/
message.rs

1use serde::{Deserialize, Serialize};
2use serde_json::Value;
3
4#[derive(Debug, Clone, Serialize, Deserialize)]
5pub struct EventMessage {
6    pub id: String,
7    pub timestamp: Option<usize>,
8    pub payload: Value,
9}
10
11impl UniqId for EventMessage {
12    fn get_id(&self) -> &String {
13        &self.id
14    }
15}
16
17pub trait UniqId {
18    fn get_id(&self) -> &String;
19}