@amqp-contract/worker-nestjs

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

📖 Full documentation →

Installation

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

Usage

import { Module } from "@nestjs/common";
import { AmqpWorkerModule } from "@amqp-contract/worker-nestjs";
import { contract } from "./contract";

@Module({
  imports: [
    AmqpWorkerModule.forRoot({
      contract,
      handlers: {
        processOrder: async (message) => {
          console.log("Processing order:", message.orderId);
        },
      },
      urls: ["amqp://localhost"],
    }),
  ],
})
export class AppModule {}

The worker automatically starts consuming messages when the module initializes and cleans up on shutdown.

Documentation

📖 Read the full documentation →

License

MIT