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
Open in Parity → Download spec.json All 102 specs