RocketMQ-Rust is a Rust reimplementation of Apache RocketMQ, a distributed message-queue system for sending and processing messages between applications. It is for Rust developers who need messaging middleware compatible with the RocketMQ protocol.
Borrowing it
Nothing to install: this file belongs to mxsm/rocketmq-rust. Take a copy, put it at the same path in your own repository, and replace the rules that are about this project with yours.
curl -O https://raw.githubusercontent.com/mxsm/rocketmq-rust/main/.agents/skills/rocketmq-rust-local-cluster/SKILL.mdgit clone --depth 1 https://github.com/mxsm/rocketmq-rustWrote this? Show the measurements
A badge with what this costs and how it scanned, read live from this page, so it follows the numbers instead of freezing them. Markdown for a README, HTML for a documentation site or a project page.
[](https://agentmods.dev/skills/mxsm/rocketmq-rust/rocketmq-rust-local-cluster)<a href="https://agentmods.dev/skills/mxsm/rocketmq-rust/rocketmq-rust-local-cluster"><img src="https://agentmods.dev/badge/skills/mxsm/rocketmq-rust/rocketmq-rust-local-cluster/github.svg" alt="Measured on agentmods" height="20"></a>Or the 80×15 button, for a site that already has a row of RSS and ATOM ones. Only the verdict fits; the numbers stay here.
<a href="https://agentmods.dev/skills/mxsm/rocketmq-rust/rocketmq-rust-local-cluster"><img src="https://agentmods.dev/badge/skills/mxsm/rocketmq-rust/rocketmq-rust-local-cluster.svg" alt="Reviewed on agentmods" width="80" height="20"></a>What it costs to keep this loaded
Counted locally with the o200k_base tokenizer, which is exact for GPT models; Claude uses its own tokenizer and its counts differ. Treat this as one consistent yardstick across the catalogue rather than a bill. Prices are per million input tokens.
| Model | Per session | Once invoked |
|---|---|---|
| Fable 5.1 | $0.00059 | $0.01724 |
| Opus 5.5 | $0.00024 | $0.00690 |
| Sonnet 5.5 | $0.00012 | $0.00345 |
| Haiku 4.5 | $0.00006 | $0.00172 |
Grade A, and why
rocketmq-rust-local-cluster scanned grade A with 0 findings against 26 rules in 11 categories — prompt injection, anti-refusal, data exfiltration, privilege escalation, supply chain, agent snooping, system-prompt leakage, SSRF and excessive agency — measured 1mo ago.
A static scan of the body, not an audit. Every finding is printed with the line that produced it so you can judge whether it matters here. A mod is markdown that instructs an agent; that is exactly why what it instructs is worth reading.
Nothing flagged
None of the 26 patterns this scan looks for appear in this file: no shell pipes, no recursive deletes, no credential paths, no hidden text, no instruction-override or anti-refusal phrasing, no agent-config snooping. That is not a guarantee, it is the absence of the things that are checkable.
How it starts
The opening of the file, as written. The whole thing — 74 lines — stays where its author put it; the contents beside it link to each section on GitHub.
RocketMQ Rust Local Cluster
Turn the requested topology into a running, verifiable local environment with isolated data and an explicit stop procedure. Use this checkout's manifests, configuration parsers, and entrypoints. Java RocketMQ scripts and old flat Broker configuration are not substitutes for the Rust services.
Select a topology
Preserve the user's topology, paths, ports, and execution method. Otherwise default to dev-single, native processes, loopback addresses, and a debug build; state the assumptions and continue. For an unspecified request for HA, select controller-ha and explain its larger resource needs. Select dev-ha when the user explicitly wants ordinary master/slave replication.
| Profile | Processes | Purpose and limits |
|---|---|---|
dev-single |
1 NameServer + 1 Broker | Minimum message round trip; no replica |
dev-ha |
2 NameServers + 1 master + 1 slave | Synchronous replication by default; no automatic writable-master promotion |
dev-ha-2m2s |
2 NameServers + 2 master/slave groups | Two distinct brokerName values; ordinary replication |
proxy-cluster |
dev-single + a separate Proxy |
gRPC ingress forwarding to the backend cluster |
proxy-local |
1 Proxy with an embedded Broker | Single-process development; no separate NameServer/Broker and no HA |
controller-ha |
2 NameServers + 3 Controllers + 3 Brokers in one group | Raft quorum, automatic Broker election, and replica synchronization |
--with-proxy adds a separate Proxy to dev-single, dev-ha, dev-ha-2m2s, or controller-ha. It adds one ingress instance; Proxy redundancy needs additional instances and an endpoint strategy when requested.
These are single-host development topologies. They do not survive loss of the host or its disks. Explain synchronous replication (SYNC_MASTER), disk flush (SYNC_FLUSH), and automatic election as separate properties.
Workflow
For status, stop, or restart requests, open the existing environment manifest and process records first. Skip configuration generation and builds unless a requested restart actually needs updated binaries. Do not create another cluster while inspecting an existing one.
What ships with it
6 files beside SKILL.md in the same directory: the scripts, references and assets a skill reads on demand. Not counted in the per-session cost; read them before you install if any of them is executable.
What this file has done since we first saw it
Hashed on every crawl. A supply-chain change to an agent config is a question of when, not whether, so the history is kept rather than the latest state alone.
- 1mo ago First seen · 74 lines · 59 tokens per session scan A b3c4d2bbe72f
rocketmq-rust-local-cluster is a skill published in the GitHub repository mxsm/rocketmq-rust (1,538 stars, last pushed today), licensed Apache-2.0. It adds 59 tokens to every session and 1,724 once invoked, about $0.0002 per session on Opus 5.5. A static security scan graded it A with 0 findings. No closer match exists in the catalogue, so it is treated as the original; first seen 2026-09-10.
rocketmq-rust-local-cluster compared with skills from other repositories
| Mod | Type | Stars | Last push | Licence | Scan | Tokens | Works with |
|---|---|---|---|---|---|---|---|
| rocketmq-rust-local-clustermxsm/rocketmq-rust | Skill | 1.5k | today | Apache-2.0 | A | 59 | Codex |
| mcp-builderHmbown/CodeWhale | Skill | 41k | 5d ago | MIT | A | 30 | Claude Code, Codex |
| azure-eventhub-rustmicrosoft/skills | Skill | 3.2k | yesterday | MIT | A | 58 | Claude Code |
| apollo-router-plugin-creatorclidey/whodb | Skill | 5.0k | yesterday | Apache-2.0 | A | 116 | Claude Code |
| cosmos-design-structAzure/azure-sdk-for-rust | Skill | 887 | today | MIT | A | 83 | Claude Code |
| claude-apiwarpdotdev/warp | Skill | 66k | yesterday | AGPL-3.0 | A | 193 | Claude Code, Codex |
| hotpath_bumppawurb/hotpath-rs | Skill | 1.9k | 19d ago | MIT | A | 99 | Claude Code |