Production-ready NATS JetStream bridge for Ruby/Rails with outbox, inbox, DLQ, and overlap-safe stream provisioning.

• Transactional outbox and idempotent inbox (optional) for exactly-once pipelines.
• Durable pull (default) or push consumers with retries, backoff, and DLQ routing.
• Auto stream provisioning with overlap protection; consumers auto-created on subscription.
• Rails-native: generators, migrations, health check, and eager-loading safety.
• Least-privilege friendly: run with auto_provision=false (stream must exist; consumers are auto-created).
• Mock NATS for fast, no-infra testing.

# Gemfile
gem "jetstream_bridge", "~> 7.1"

bundle install
bin/rails g jetstream_bridge:install
bin/rails db:migrate

The install generator creates the initializer, migrations, and optional health check scaffold. For full configuration options and non-Rails boot flows, see docs/GETTING_STARTED.md.

Publish:

JetstreamBridge.publish(event_type: "user.created", resource_type: "user", payload: { id: 1 })

Consume:

consumer = JetstreamBridge::Consumer.new do |event|
  User.upsert({ id: event.payload["id"] })
end
consumer.run!

• Getting Started - Setup, configuration, and basic usage
• API Reference - Complete API documentation for all public methods
• Architecture & Topology - Internal architecture, message flow, and patterns
• Production Guide - Production deployment and monitoring
• Restricted Permissions & Provisioning - Manual provisioning and security
• Testing with Mock NATS - Fast, no-infra testing
• Reference Examples (Rails 7) - Non-restrictive and restrictive Dockerized examples with E2E tests

MIT