There is no matching event handler defined in the remote service. Event pattern: undefined error message about nestjs-google-pubsub-microservice HOT 10 CLOSED

Hi, could you provide pubsub message example which client sends?

from nestjs-google-pubsub-microservice.

@p-fedyukovich Sure

message example

{
  "broker": "Smart Prime Group Ltd.",
  "time": "2022-02-14T00:21:01.137Z",
  "symbol": "SPA35",
  "ask": 50.25,
  "bid": 60.50,
  "volume": 6500,
  "publisherTime": "2022-02-14T00:21:01.137Z"
}

here is my topic schema

{
  "type": "record",
  "name": "Avro",
  "fields": [
    {
      "name": "broker",
      "type": "string"
    },
    {
      "name": "time",
      "type": "string"
    },
    {
      "name": "symbol",
      "type": "string"
    },
    {
      "name": "ask",
      "type": "double"
    },
    {
      "name": "bid",
      "type": "double"
    },
    {
      "name": "volume",
      "type": "double"
    },
    {
      "name": "publisherTime",
      "type": "string"
    }
  ]
}

p.s I tried with this lib and it's working fine https://github.com/crallen/nestjs-google-pubsub#readme

from nestjs-google-pubsub-microservice.

@p-fedyukovich Sure

message example

{
  "broker": "Smart Prime Group Ltd.",
  "time": "2022-02-14T00:21:01.137Z",
  "symbol": "SPA35",
  "ask": 50.25,
  "bid": 60.50,
  "volume": 6500,
  "publisherTime": "2022-02-14T00:21:01.137Z"
}

here is my topic schema

{
  "type": "record",
  "name": "Avro",
  "fields": [
    {
      "name": "broker",
      "type": "string"
    },
    {
      "name": "time",
      "type": "string"
    },
    {
      "name": "symbol",
      "type": "string"
    },
    {
      "name": "ask",
      "type": "double"
    },
    {
      "name": "bid",
      "type": "double"
    },
    {
      "name": "volume",
      "type": "double"
    },
    {
      "name": "publisherTime",
      "type": "string"
    }
  ]
}

p.s I tried with this lib and it's working fine https://github.com/crallen/nestjs-google-pubsub#readme

Your message data format is wrong because it should have metadata for correct selecting message handler. If you use your own message dispatcher it should produce message in such format

{
  "pattern": "notifications",
  "eventId": "any string value for that message which keeps idemopotency",
  "data": "Your message payload"
}

from nestjs-google-pubsub-microservice.

Thank you for reply.
So what changes exactly I need to make in my message and schema to make it work?

from nestjs-google-pubsub-microservice.

I provided the message structure, you should update your message producer to fit the message structure

from nestjs-google-pubsub-microservice.

Hi @p-fedyukovich I have trouble publishing the message, could you please provide a working example here or to the ReadMe file?

from nestjs-google-pubsub-microservice.

Hi @p-fedyukovich I have trouble publishing the message, could you please provide a working example here or to the ReadMe file?

Hi, there are examples in test files.

import {
  Body,
  Controller,
  HttpCode,
  OnApplicationShutdown,
  Post,
  Query,
} from '@nestjs/common';
import {
  ClientProxy,
  EventPattern,
  MessagePattern,
} from '@nestjs/microservices';
import { GCPubSubClient } from '../../lib';

@Controller()
export class GCPubSubController implements OnApplicationShutdown {
  client: ClientProxy;

  constructor() {
    this.client = new GCPubSubClient({
      client: {
        apiEndpoint: 'localhost:8681',
        projectId: 'microservice',
      },
    });
  }

  onApplicationShutdown(signal?: string) {
    return this.client.close();
  }

  @Post('notify')
  async sendNotification(): Promise<any> {
    return this.client.emit('notification', true);
  }
}

from nestjs-google-pubsub-microservice.