watermelon_proto/
message.rs

1use bytes::Bytes;
2
3use crate::{StatusCode, Subject, headers::HeaderMap, subscription_id::SubscriptionId};
4
5#[derive(Debug, Clone, PartialEq, Eq)]
6pub struct MessageBase {
7    pub subject: Subject,
8    pub reply_subject: Option<Subject>,
9    pub headers: HeaderMap,
10    pub payload: Bytes,
11}
12
13#[derive(Debug, Clone, PartialEq, Eq)]
14pub struct ServerMessage {
15    pub status_code: Option<StatusCode>,
16    pub subscription_id: SubscriptionId,
17    pub base: MessageBase,
18}