catalog / infra

Message Broker

Publish, route and consume messages with the delivery guarantee written down.

17 capabilities 1 sections reference specification

Build against it

# give your agent the catalog — no account, no install
claude mcp add provespec -- npx -y provespec-mcp

# then, from any agent session
spec_get(slug: "message-broker")                → the capability tree
spec_checklist(slug: "message-broker")          → the questions to answer
spec_grade(slug: "message-broker", grades: [...])  → parity % + the gap list

# or just fetch it
curl https://provespec.com/catalog/message-broker/spec.json

Grade every capability below as yes · partial · no · na, with a file reference as evidence. Whatever you leave ungraded counts as missing — the gap list is the work queue.

Or just paste this to your agent

Use the ProveSpec MCP server. Fetch the "message-broker" spec with
spec_get, then walk spec_checklist and grade this repository against it —
one verdict per capability, each with a file reference as the note.
Call spec_grade with the results and give me the gap list as the plan.

If the server is not registered, add it first:
  claude mcp add provespec -- npx -y provespec-mcp

The specification

AI 17

Publish
  • Send a message to a topic or queue
  • Publisher confirmation the broker acknowledges durability
  • Message headers and content type
Routing
  • Point-to-point queues and pub/sub topics
  • Routing keys or subject patterns
  • Fan-out to multiple consumer groups
Consume
  • Push and pull consumption
  • Explicit acknowledgement with redelivery on failure
  • Prefetch limit per consumer backpressure
Guarantees
  • Delivery semantics stated at-most-once / at-least-once / effectively-once
  • Ordering guarantee and its scope per partition or per key
Durability
  • Persistent messages survive restart
  • Replication factor and acknowledgement quorum
Failure
  • Dead-letter destination after N redeliveries
  • Poison-message handling does not stall the queue
Retention
  • Time or size based retention; replay from an offset
Operations
  • Lag, throughput and consumer-group metrics
Download spec.json All 71 specs