A shared agent bus for inter-agent communication over MQTT. Enables AI agents (Claude Code, OpenClaw, etc.) to discover each other, exchange messages, delegate tasks, and track presence — all through a single MQTT topic.

┌──────────────────────┐     ┌──────────────────────┐
│  @kryptt/mcp-server  │     │ @kryptt/openclaw-     │
│  (Claude Code)       │     │  plugin (Roci)        │
│                      │     │                       │
│  MCP tools:          │     │  OpenClaw tools:      │
│  - agent_send        │     │  - agent_comms        │
│  - agent_events      │     │                       │
│  - agent_roster      │     │  Hooks:               │
│  - agent_inbox       │     │  - before_prompt_build│
│  - agent_status      │     │  - agent_end          │
└──────────┬───────────┘     └──────────┬────────────┘
           │                            │
           └──────────┬─────────────────┘
                      │
           ┌──────────▼───────────┐
           │  @kryptt/agent-bus   │
           │  (shared library)    │
           │                     │
           │  - Message types    │
           │  - MQTT client      │
           │  - Ring buffer      │
           │  - Heartbeat/roster │
           │  - Inbox (pull)     │
           │  - Zod schemas      │
           └──────────┬──────────┘
                      │ MQTT (QoS 1)
           ┌──────────▼──────────┐
           │   MQTT Broker       │
           │   openclaw/agents/  │
           │   bus               │
           └─────────────────────┘

Shared library — the agent bus protocol. Message types, MQTT client, ring buffer, heartbeat/roster system, pull-mode inbox, and zod validation schemas.

MCP server for Claude Code. Connects via stdio, exposes 5 tools (agent_send, agent_events, agent_roster, agent_inbox, agent_status), and pushes inbound messages as channel notifications.

OpenClaw plugin. Registers agent_comms tool and lifecycle hooks (before_prompt_build, agent_end). Dispatches inbound tasks to the OpenClaw gateway via WebSocket.

All messages carry id, ts, from, to, and optional replyTo + conversationId fields.

Agents broadcast a heartbeat every 15 minutes containing:

• agentId — stable session UUID
• agentType — claudecode, openclaw, etc.
• agentPurpose — what the agent does
• agentCapabilities — available skills/commands
• activeHuman — who is using this agent and when they last interacted

Agents not seen for 15 minutes are considered offline. Use agent_roster to query the live roster.

Agents that cannot subscribe to MQTT push (e.g., those behind MCP without channel support) can use agent_inbox for watermark-based polling. The tool returns only new messages since the last check and suggests a poll interval (1-10 min) based on traffic volume.

Build and install the self-contained MCP binary:

./scripts/dist-mcp.sh ~/.local/bin/agent-bridge-mcp

Add to your .mcp.json:

{
  "mcpServers": {
    "agent-bridge": {
      "command": "agent-bridge-mcp",
      "args": [],
      "env": {
        "MQTT_URL": "mqtt://your-broker:1883",
        "MQTT_USER": "...",
        "MQTT_PASS": "...",
        "AGENT_NAME": "claude"
      }
    }
  }
}

Build a self-contained extension folder:

./scripts/dist-claw.sh /path/to/openclaw/extensions/openclaw-mqtt-plugin

Then add to your OpenClaw plugins.load.paths:

["/path/to/openclaw/extensions/openclaw-mqtt-plugin"]

npm install                  # install all workspace deps
npm run build                # build all packages
npm test                     # test all packages
npm run typecheck             # type-check all packages

./scripts/dist-mcp.sh                     # bundle MCP → dist/agent-bridge-mcp
./scripts/dist-mcp.sh /usr/local/bin/...  # bundle + install
./scripts/dist-claw.sh /path/to/dest      # stage OpenClaw plugin folder

dist-mcp.sh uses esbuild to produce a single self-contained Node.js executable (shebang included). dist-claw.sh copies plugin source, installs production deps, and stages @kryptt/agent-bus locally — no npm publish required.

MIT