Skip to main content

EventBus / NATS JetStream

EventBus is the platform abstraction. NATS JetStream is the production-shaped implementation.

Defaults:

  • Stream: oneprotect-events
  • Consumer: oneprotect-worker
  • Subject prefix: oneprotect.events
  • Subject shape: oneprotect.events.<event_type>

The API publishes contract-clean envelopes. The worker consumes device.discovered and runs the existing tenant-scoped workflow.

Run:

make test-nats
make smoke-nats

Current gaps:

  • Dedicated DLQ stream/subject.
  • Consumer lag metrics.
  • Transactional outbox dispatcher.