nestjs-nsq v0.0.3

nestjs-nsq

nestjs nsq 客户端

Installation

$ npm install nestjs-nsq nsqjs

use

import { Module } from "@nestjs/common";
import { ConfigService } from "@nestjs/config";
import { NSQModule } from "nestjs-nsq";

@Module({
  imports: [
    NSQModule.forRootAsync({
      inject: [ConfigService],
      useFactory: async (configService: ConfigService) => ({
        nsqdTCPAddresses: configService.get('nsqdTCPAddresses'),
      }),
    }),
  ],
})
export class AppModule {}

import { NSQService } from "nestjs-nsq";

@Injectable()
export class AppService {
  constructor(
    private nsqService: NSQService,
  ) {}

  call(topic: string, channel: string, data: any) {
    return this.nsqService.emit(topic, channel, data);
  }
}