@amqp-contract/client-nestjs

NestJS integration for @amqp-contract/client. Type-safe AMQP message publishing with automatic lifecycle management.

📖 Full documentation →

Installation

pnpm add @amqp-contract/client-nestjs @amqp-contract/client @amqp-contract/contract amqplib

Usage

import { Injectable, Module } from "@nestjs/common";
import { AmqpClientModule, AmqpClientService } from "@amqp-contract/client-nestjs";
import { contract } from "./contract";

@Module({
  imports: [
    AmqpClientModule.forRoot({
      contract,
      urls: ["amqp://localhost"],
    }),
  ],
})
export class AppModule {}

@Injectable()
export class OrderService {
  constructor(private readonly client: AmqpClientService<typeof contract>) {}

  async createOrder(orderId: string, amount: number) {
    await this.client.publish("orderCreated", { orderId, amount }).resultToPromise();
  }
}

The client automatically connects when the module initializes and cleans up on shutdown.

Documentation

📖 Read the full documentation →

License

MIT