@e3o/pubsub

pubsub

How to install

• In your package.json file, add @e3o/pubsub in your dependencies followed by the version number or run

npm install @e3o/pubsub

• Import the PubSubModule in your AppModule and pubsub subscriptions

import { PubSubModule } from '@e3o/pubsub'
import { subscriptions } from './../automation/pubsub/conf-topic-subscription.json'

• Register the module

@Module({
  imports: [
    PubSubModule.register({
      projectId: config.get('PUBSUB_PROJECT_ID'),
      keyFilename: config.get('PUBSUB_KEY_FILENAME'),
      origin: config.get('PUBSUB_ORIGIN'),
      prefix: config.get('PUBSUB_PREFIX'),
      subscriptions,
      listenOnStartUp, //boolean : start immediatly pulling (used for blue/green)
    }),
  ],

• Start the microservice in main.ts

import { PubSubServer } from '@e3o/pubsub'

async function bootstrap() {
  const app = await NestFactory.create(AppModule)
   // Start PubSub microservice
  app.connectMicroservice({ strategy: app.get(PubSubServer) })
  await app.startAllMicroservicesAsync()
  ...

Usage

• Listening to topics (using EventPattern decorator)

  @EventPattern('MESSAGE_KEY')
  handleDeliveyInit(message: any): void {
    ...
  }

• Sending message to topics

  constructor(
    @Inject(PUBSUB_CLIENT) private readonly client: ClientProxy,
  ) {}

  public test() {
    this.client.emit('MESSAGE_KEY', { message : "test"})
  }