rocketmq-client 0.1.0

Rust client binding for Apache RocketMQ
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

//!
//! Define Message struct. Application data are enveloped in `Message` before publishing to Apache RocketMQ.
//!
use bytes;
use std::collections::HashMap;
use std::vec::Vec;

pub struct Message {
    /// In the publisher-subscriber model, a topic is an addresses where messages are delivered to and subscribed from.
    pub topic: String,

    pub tag: String,

    pub keys: Vec<String>,

    /// User defined attributes in form of key-value paris.
    /// Attributes are indexed by backend broker servers, thus, may be utilized to query.
    pub attributes: HashMap<String, String>,

    /// System properties
    ///
    /// System properties include key-value pairs to modify how messages are delivered to subscribers. For example, publishers
    /// may publish a timed message, which should be invisible to subscribers before specified time point.
    pub(crate) properties: HashMap<String, String>,

    pub body: bytes::Bytes,
}