RobustMQ 0.3.5

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.

Protocol operations:

Full spec: docs/mq9-protocol.md

SDK status

Integrations

Quick start

Python

pip install robustmq

from robustmq.mq9 import Client, Priority

async with Client("nats://demo.robustmq.com:4222") as client:
    mailbox = await client.create(ttl=3600)
    await client.send(mailbox.mail_id, b"hello", priority=Priority.NORMAL)

    async def handler(msg):
        print(msg.payload)

    await client.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";

const client = new MQ9Client({ server: "nats://demo.robustmq.com:4222" });
await client.connect();
const mailbox = await client.create({ ttl: 3600 });
await client.send(mailbox.mailId, "hello", "normal");

Java (Maven)

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

import com.robustmq.mq9.*;

MQ9Client client = new MQ9Client("nats://demo.robustmq.com:4222");
client.connect();
Mailbox mailbox = client.create(3600).get();
client.send(mailbox.getMailId(), "hello".getBytes(), Priority.NORMAL).get();

Java (Gradle)

implementation 'com.robustmq:robustmq:0.3.5'

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

using RobustMQ.Mq9;

await using var client = new MQ9Client("nats://demo.robustmq.com:4222");
await client.ConnectAsync();
var mailbox = await client.CreateAsync(3600);
await client.SendAsync(mailbox.MailId, "hello"u8.ToArray(), Priority.Normal);

SDK documentation

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 (high / normal / low priority)
3. Subscribe and print received messages
4. List mailbox metadata, delete one message
5. Create a public mailbox

# Python
cd demo/demo-python && pip install -r requirements.txt && python demo.py

# Go
cd demo/demo-go && go run .

# JavaScript
cd demo/demo-javascript && npm install && npm start

# Java
cd demo/demo-java && mvn compile exec:java

# Rust
cd demo/demo-rust && cargo run

# C#
cd demo/demo-csharp && dotnet run

# langchain-mq9
cd demo/demo-langchain-mq9 && pip install -r requirements.txt && python 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
VERSION                   # Canonical version (currently 0.3.5)

Related

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