google-pubsub-client

客户端扩展了客户端Proxy类,并需要使用@algoan/pubsub来推翻放出方法.

⚠️ 此客户端只覆盖 抽象 dispatchEvent 方法因此,只有 client#emit 方法可以调用.

安装

npm install --save @algoan/pubsub @algoan/nestjs-google-pubsub-client

使用量

要即时化 GCPubSubClient :

模块数字 :

// app.module.ts
import { Module } from '@nestjs/common';

import { GCPubSubClient } from '../../src';
import { AppController } from './app.controller';
import { AppService } from './app.service';

/**
 * App module
 */
@Module({
  controllers: [AppController],
  providers: [
    AppService,
    {
      provide: 'PUBSUB_CLIENT',
      useFactory: () => {
        // Use a factory to add you custom options
        return new GCPubSubClient({});
      },
    },
  ],
})
export class AppModule {}

服务数字 :

import { Inject, OnModuleInit } from '@nestjs/common';
import { ClientProxy } from '@nestjs/microservices';

/**
 * Fake app service
 */
export class AppService implements OnModuleInit {
  constructor(@Inject('PUBSUB_CLIENT') private readonly client: ClientProxy) {}

  /**
   * Connect the client proxy on module init
   * NOTE: this is optional with GooglePubSubClient. It is called anyway in the emit method
   * See https://github.com/nestjs/nest/blob/master/packages/microservices/client/client-proxy.ts#L67
   */
  public async onModuleInit(): Promise<void> {
    await this.client.connect();
  }
  /**
   * Emit a test event
   * @param data Payload sent
   */
  public emitTestEvent(data: { hello: string }): void {
    this.client.emit('test_event', data);
  }
}

new GCPubSubClient(options)

启动新的 Google Cloud PubSub 客户端代理 .

• options: 与GC PubSub实例有关的选项。 关于备选方案的更详细情况 这里