An internal pub/sub event bus for decoupling plugins and services within your nSelf stack. Publish events from one plugin, subscribe from another, with guaranteed fan-out delivery, dead-letter queuing, and full event replay. A lightweight alternative to Kafka or RabbitMQ for intra-stack coordination.
Set your license key with nself license set nself_pro_... before installing.
nself license set nself_pro_...
nself plugin install event-bus
nself build
nself startcurl -X POST http://127.0.0.1:3097/event-bus/publish \
-H "Content-Type: application/json" \
-d '{
"topic": "user.created",
"payload": {"user_id": "abc123", "email": "user@example.com"}
}'curl -X POST http://127.0.0.1:3097/event-bus/subscribe \
-H "Content-Type: application/json" \
-d '{
"topic": "user.created",
"endpoint": "http://127.0.0.1:3050/notify/on-new-user",
"name": "notify-on-signup"
}'user.*)| Endpoint | Method | Description |
|---|---|---|
/event-bus/publish | POST | Publish an event to a topic |
/event-bus/subscribe | POST | Register a webhook subscriber |
/event-bus/subscriptions | GET | List all active subscriptions |
/event-bus/replay | POST | Replay events for a topic or time range |
/event-bus/dlq | GET | Inspect dead-letter queue |
/health | GET | Plugin health check |
nself plugin remove event-busCategory: Infrastructure | Language: Go | Last Updated: April 2026 | Plugin Version 1.0.0