Global Broadcast Bus & Publications

What you'll learn

Subscribe to all events across all agents, and use the publications system for cross-agent messaging.

Global SSE stream

# All events from all agents
curl -N "http://localhost:7475/v1/stream" \
  -H "Authorization: Bearer spx_root_YOUR_ROOT_KEY"

Events include agent_id so you can filter client-side:

` event: record data: {"agent_id":"orders","content_hash":"...","payload":{"status":"paid"}}

event: record data: {"agent_id":"users","content_hash":"...","payload":{"plan":"enterprise"}} `

Publications — broadcast a message

curl -s -X POST http://localhost:7475/v1/publications \
  -H "Content-Type: application/json" \
  -H "Authorization: Bearer spx_root_YOUR_ROOT_KEY" \
  -d '{
    "topic":   "order.paid",
    "payload": {"order_id": "ord_001", "amount": 299.99}
  }' | python3 -m json.tool

All subscribers to order.paid receive the event instantly.

Subscribe to a topic

curl -N "http://localhost:7475/v1/publications/subscribe?topic=order.paid" \
  -H "Authorization: Bearer spx_root_YOUR_ROOT_KEY"

Challenge

Open a global SSE stream. Write records to 3 different agents. Confirm the global stream receives all 3 events with their respective agent_id values.

---