RobustMQ SDK

Multi-language client SDK for RobustMQ — a unified messaging engine built for the AI era.

RobustMQ is a single-binary broker that natively supports MQTT, Kafka, NATS, AMQP, and mq9 on a shared storage layer.

mq9: AI Agent mailbox protocol

mq9 gives every agent a durable mailbox. Messages persist until TTL expires — senders and receivers do not need to be online simultaneously. It is purpose-built for multi-agent systems where tasks, results, and signals must survive disconnections and be delivered in priority order.

Concept	Description
Mailbox	Agent's address. Private (UUID) or public (user-defined name). TTL-driven, auto-cleaned.
Priority	critical / urgent / normal (default, no suffix). Cross-priority ordering guaranteed by storage.
Store-first	Subscriber gets all non-expired messages on connect, then real-time going forward.
Queue group	Multiple subscribers sharing a group receive each message exactly once.

Protocol operations:

Operation	Subject
Create mailbox	$mq9.AI.MAILBOX.CREATE
Send message (default)	$mq9.AI.MAILBOX.MSG.{mail_id}
Send message (urgent/critical)	$mq9.AI.MAILBOX.MSG.{mail_id}.{priority}
Subscribe	$mq9.AI.MAILBOX.MSG.{mail_id}.*
List metadata	$mq9.AI.MAILBOX.LIST.{mail_id}
Delete message	$mq9.AI.MAILBOX.DELETE.{mail_id}.{msg_id}

Full spec: docs/mq9-protocol.md

---

SDK status

Language	Package	Version	Install
Python	robustmq	1.0.1	pip install robustmq
Go	github.com/robustmq/robustmq-sdk/go	v1.0.1	go get github.com/robustmq/robustmq-sdk/go
JavaScript	@robustmq/sdk	1.0.1	npm install @robustmq/sdk
Java	com.robustmq:robustmq	1.0.1	Maven / Gradle (see below)
Rust	robustmq	1.0.1	cargo add robustmq
C#	RobustMQ	1.0.1	dotnet add package RobustMQ

Integrations

Package	Description	Install
langchain-mq9	LangChain tools for mq9 — give your Agents a persistent async inbox	pip install langchain-mq9

---

Quick start

Python

pip install robustmq

fromrobustmq.mq9importClient, PriorityasyncwithClient("nats://demo.robustmq.com:4222") asclient:
mailbox=awaitclient.create(ttl=3600)
awaitclient.send(mailbox.mail_id, b"hello", priority=Priority.NORMAL)
asyncdefhandler(msg):
print(msg.payload)
awaitclient.subscribe(mailbox.mail_id, handler)

Go

go get github.com/robustmq/robustmq-sdk/go

import"github.com/robustmq/robustmq-sdk/go/mq9"c:=mq9.NewMQ9Client("nats://demo.robustmq.com:4222")
c.Connect()
mailbox, _:=c.Create(3600)
c.Send(mailbox.MailID, []byte("hello"), mq9.Normal)

JavaScript / TypeScript

npm install @robustmq/sdk

import{MQ9Client}from"@robustmq/sdk/mq9";constclient=newMQ9Client({server: "nats://demo.robustmq.com:4222"});awaitclient.connect();constmailbox=awaitclient.create({ttl: 3600});awaitclient.send(mailbox.mailId,"hello","normal");

Java (Maven)

<dependency>
<groupId>com.robustmq</groupId>
<artifactId>robustmq</artifactId>
<version>1.0.1</version>
</dependency>

importcom.robustmq.mq9.*;
MQ9Clientclient = newMQ9Client("nats://demo.robustmq.com:4222");
client.connect();
Mailboxmailbox = client.create(3600).get();
client.send(mailbox.getMailId(), "hello".getBytes(), Priority.NORMAL).get();

Java (Gradle)

implementation 'com.robustmq:robustmq:1.0.1'

Rust

[dependencies]
robustmq = "0.3"tokio = { version = "1", features = ["full"] }

use robustmq::mq9::{MQ9Client,Priority};let client = MQ9Client::connect("nats://demo.robustmq.com:4222").await?;let mailbox = client.create(3600,false,"","").await?;
client.send(&mailbox.mail_id,b"hello",Priority::Normal).await?;

C#

dotnet add package RobustMQ

usingRobustMQ.Mq9;awaitusingvarclient=newMQ9Client("nats://demo.robustmq.com:4222");awaitclient.ConnectAsync();varmailbox=awaitclient.CreateAsync(3600);awaitclient.SendAsync(mailbox.MailId,"hello"u8.ToArray(),Priority.Normal);

---

AI Framework Integration

mq9 integrates with popular AI orchestration frameworks. Each Agent node gets a persistent mailbox — tasks and results survive disconnections and are delivered in priority order.

LangChain

langchain-mq9 provides six LangChain tools covering all mq9 protocol operations. Drop them into any LangChain Agent or LangGraph node.

fromlangchain_mq9importMq9Toolkittools=Mq9Toolkit(server="nats://demo.robustmq.com:4222").get_tools()
# CreateMailboxTool, CreatePublicMailboxTool, SendMessageTool,# GetMessagesTool, ListMessagesTool, DeleteMessageTool

LangGraph

Each LangGraph node can own a private mq9 mailbox and communicate with other nodes asynchronously — the graph edges carry state, while mq9 carries the payloads.

fromlangchain_mq9importCreateMailboxTool, SendMessageToolasyncdefnode_writer(state):
create=CreateMailboxTool(server="nats://demo.robustmq.com:4222")
mail_id=awaitcreate._arun(ttl=120)
...

Full examples: demo/demo-langchain-mq9/ · demo/demo-langgraph/

---

SDK documentation

Language	Docs	Demo
Python	docs/python.md	demo/demo-python/
Go	docs/go.md	demo/demo-go/
JavaScript	docs/javascript.md	demo/demo-javascript/
Java	docs/java.md	demo/demo-java/
C#	docs/csharp.md	demo/demo-csharp/
Rust	docs/rust.md	demo/demo-rust/
langchain-mq9	docs/langchain-mq9.md	demo/demo-langchain-mq9/
Multi-agent (Python ↔ Go)	—	demo/demo-multi-agent/
LangGraph workflow	—	demo/demo-langgraph/

---

Running the demo

Each demo is a standalone project that connects to nats://demo.robustmq.com:4222 and runs the same scenario:

1. Create a private mailbox (TTL 60s)
2. Send 3 messages (critical / urgent / normal priority)
3. Subscribe and print received messages
4. List mailbox metadata, delete one message
5. Create a public mailbox

# Pythoncd demo/demo-python && pip install -r requirements.txt && python demo.py
# Gocd demo/demo-go && go run .# JavaScriptcd demo/demo-javascript && npm install && npm start
# Javacd demo/demo-java && mvn compile exec:java
# Rustcd demo/demo-rust && cargo run
# C#cd demo/demo-csharp && dotnet run
# langchain-mq9cd demo/demo-langchain-mq9 && pip install -r requirements.txt && python demo.py
# Multi-agent (Python + Go, two terminals)cd demo/demo-multi-agent && go run agent_b.go # terminal 1cd demo/demo-multi-agent && python agent_a.py # terminal 2# LangGraph workflowcd demo/demo-langgraph && pip install robustmq langchain-core langgraph langchain-openai
export OPENAI_API_KEY=sk-...
python langgraph_mq9_demo.py

---

Repository layout

python/ # Python SDK
go/ # Go SDK
javascript/ # JavaScript/TypeScript SDK
java/ # Java SDK
csharp/ # C# SDK
rust/ # Rust SDK
langchain-mq9/ # LangChain integration package
docs/ # SDK docs + protocol spec
demo/
demo-python/ # Python standalone demo
demo-go/ # Go standalone demo
demo-javascript/ # JavaScript standalone demo
demo-java/ # Java standalone demo (Maven)
demo-rust/ # Rust standalone demo
demo-csharp/ # C# standalone demo
demo-langchain-mq9/ # langchain-mq9 demo
demo-multi-agent/ # cross-language multi-agent demo (Python + Go)
demo-langgraph/ # LangGraph workflow demo
VERSION # Canonical version (currently 1.0.1)

---

Related

• RobustMQ — the broker
• mq9 Protocol Specification — full protocol reference