基于 Stan.js 包的 Nest.js 微服务 NATS 流策略和客户端

本模块提供基于 Stan.js 软件包的 NATS 流服务器策略和客户端。

安装

npm i --save @nestjs-ex/stan-strategy

用法

要使用 STAN 传输器,请将以下选项对象传递给 createMicroservice() 方法:

import { NestFactory } from '@nestjs/core';
import { StanStrategy } from '@nestjs-ex/stan-strategy';
import { AppModule } from './app.module';

async function bootstrap() {
  const app = await NestFactory.createMicroservice(AppModule, {
    strategy: new StanStrategy({
      url: 'nats://localhost:4222',
      queueGroupName: 'my-queue-group',
    }),
  });
  await app.listen(() => console.log('Microservice is listening'));
}
bootstrap();
zip 文件大小:109.72KB