Struct Message

pub struct Message<T: Serialize + Debug> { /* private fields */ }

Implementations

impl<T: Serialize + Debug> Message<T>

pub fn new( topic: String, headers: HashMap<String, String>, data: T, key: String, ) -> Self

Creates a new Message struct

Arguments

• topic - A topic that the message should be published to
• headers - A HashMap that holds the headers that should be published with the message
• data - A generic type that holds the data that should be published, data should be serializable
• key - A key that should be used to publish the message

Trait Implementations

impl<T: Debug + Serialize + Debug> Debug for Message<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.