nestjs-jetstream

import { Module } from '@nestjs/common';
import { JetstreamModule } from '@horizon-republic/nestjs-jetstream';

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

import { Controller, Logger } from '@nestjs/common';
import { EventPattern, Payload } from '@nestjs/microservices';

// At-least-once. Retries on throw. Traced end-to-end.
@Controller()
export class OrdersController {
  private readonly log = new Logger(OrdersController.name);

  @EventPattern('orders.created')
  async onCreated(@Payload() order: Order) {
    await this.billing.charge(order);
    this.log.log(`charged ${order.id}`);
  }

  @MessagePattern('orders.lookup')
  lookup(@Payload() id: string) {
    return this.orders.find(id);
  }
}