1
2
3
4
5
6
7
8

use bytes::Bytes;

pub struct Message {
    /// The topic this message was received on.
    pub topic: String,
    /// The message payload data.
    pub payload: Bytes,
}