What you get

• At-least-once delivery — every event acked after the handler resolves; bounded retries with exponential backoff.
• Broadcast — one message reaches every running pod via per-service durable consumers.
• Ordered delivery — sequential per partition key without giving up horizontal scale.
• RPC — Core for speed, JetStream for durability — same @MessagePattern either way.
• DLQ — typed sink with original headers preserved after retries are exhausted.
• Scheduled messages, per-message TTL, health checks, graceful shutdown — all the production levers.
• OpenTelemetry-compatible — W3C traceparent propagated through every hop.

Install

npm i @horizon-republic/nestjs-jetstream

Quick Start

// app.module.ts
@Module({
  imports: [
    JetstreamModule.forRoot({ servers: ['nats://localhost:4222'] }),
  ],
})
export class AppModule {}

// orders.controller.ts
@Controller()
export class OrdersController {
  @EventPattern('orders.created')
  async onCreated(@Payload() order: Order) {
    await this.billing.charge(order);
  }
}

That's it. At-least-once. Retries on throw. Traced end-to-end.

The full configuration surface, every pattern, and the production checklist live in the documentation.

Quality

The transport is covered by an extensive test suite (unit and integration) — see the Codecov report above.

Runnable demos for most supported patterns live under examples/.

MIT · © 2026 Horizon Republic · Changelog · Contributing · Security