Method getPublisher

packages/microservices/server/server-mqtt.ts:169–193

(
    client: MqttClient,
    context: MqttContext,
    id: string,
  )

  }

  public getPublisher(
    client: MqttClient,
    context: MqttContext,
    id: string,
  ): any {
    return (response: any) => {
      Object.assign(response, { id });

      const options =
        isObject(response?.data) && response.data instanceof MqttRecord
          ? (response.data as MqttRecord)?.options
          : {};
      delete response?.data?.options;

      const outgoingResponse: string | Buffer =
        this.serializer.serialize(response);

      this.onProcessingEndHook?.(this.transportId, context);
      return client.publish(
        this.getReplyPattern(context.getTopic()),
        outgoingResponse,
        options,
      );
    };
  }

  public parseMessage(content: any): ReadPacket & PacketId {
    try {