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

//!
//! Messaging are about publishing and subscribing messages. `Publisher` is the struct to utilize to deliver message to broker.
//!
use crate::message::Message;

struct Publisher {
    group: String,
}

impl Publisher {
    pub fn new(group: &str) -> Self {
        Publisher {
            group: group.to_owned(),
        }
    }

    pub fn publish(&mut self, message: &Message) {}
}