@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 { Future, Result } from "@swan-io/boxed";
import { contract } from "./contract";

@Module({
  imports: [
    AmqpWorkerModule.forRoot({
      contract,
      handlers: {
        processOrder: ({ payload }) => {
          console.log("Processing order:", payload.orderId);
          return Future.value(Result.Ok(undefined));
        },
      },
      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