@babelqueue/nestjs

Polyglot Queues, Simplified. A NestJS adapter for BabelQueue: an injectable publisher (over BullMQ) that emits the canonical BabelQueue envelope, so NestJS services interoperate with the PHP/Laravel, Python, Go, Java and .NET SDKs.

npm install @babelqueue/nestjs @nestjs/common bullmq

Register the module

import { Module } from "@nestjs/common";
import { BabelQueueModule } from "@babelqueue/nestjs";

@Module({
  imports: [
    BabelQueueModule.forRoot({
      queue: "orders",
      connection: { host: "localhost", port: 6379 },
    }),
  ],
})
export class AppModule {}

Produce

import { Injectable } from "@nestjs/common";
import { BabelQueuePublisher } from "@babelqueue/nestjs";

@Injectable()
export class Orders {
  constructor(private readonly babelQueue: BabelQueuePublisher) {}

  create() {
    return this.babelQueue.publish("urn:babel:orders:created", { order_id: 1042 });
  }
}

Consume

Build a BullMQ worker with the re-exported processor (URN routing):

import { Worker } from "bullmq";
import { processor } from "@babelqueue/nestjs";

new Worker("orders", processor({
  "urn:babel:orders:created": async (env) => { /* ... */ },
}), { connection: { host: "localhost", port: 6379 } });

License

MIT © Muhammet Şafak · babelqueue.com