rocketmq

Crates.iorocketmq
lib.rsrocketmq
version5.0.0
sourcesrc
created_at2020-08-10 09:30:26.514474
updated_at2023-08-07 06:51:30.300563
descriptionRust client for Apache RocketMQ
homepage
repositoryhttps://github.com/apache/rocketmq-clients/tree/master/rust
max_upload_size
id274989
size397,987
SSpirits (ShadowySpirits)

documentation

https://docs.rs/rocketmq

README

The Rust Implementation of Apache RocketMQ Client

Codecov-rust Crates.io docs.rs

RocketMQ Website

Overview

Here is the rust implementation of the client for Apache RocketMQ. Different from the remoting-based client, the current implementation is based on separating architecture for computing and storage, which is the more recommended way to access the RocketMQ service.

Here are some preparations you may need to know Quick Start.

Getting Started

Requirements

  1. rust toolchain, rocketmq's MSRV is 1.61.
  2. protoc 3.15.0+
  3. setup name server, broker, and proxy.

Run Tests

cargo llvm-cov --ignore-filename-regex pb/ --open

Run Example

Run the following command to start the example:

# send message via producer
cargo run --example producer

# consume message via simple consumer
cargo run --example simple_consumer
Commit count: 0

cargo fmt