nest-mqtt icon indicating copy to clipboard operation
nest-mqtt copied to clipboard

Tried to publish but returned TypeError: this.mqttService.publish is not a function

Open Crypto-KK opened this issue 4 years ago • 0 comments

  constructor(
    @Inject(MqttService) private readonly mqttService: MqttService,
  ) {}

  @Subscribe('/iot/test/#')
  test(@Payload() payload) {
    console.log(payload)
    try {
      this.mqttService.publish("/test", {a: 1}, { qos: 0 })
    } catch (err) {
      console.error(err)
    }
  }

return this

TypeError: this.mqttService.publish is not a function
    at TestService.test (/Volumes/SSD/Development/nestjs/lege-iot-nest/dist/mqtt/service/TestService.js:25:30)
    at MqttClient.<anonymous> (/Volumes/SSD/Development/nestjs/lege-iot-nest/node_modules/[email protected]@nest-mqtt/dist/mqtt.explorer.js:120:64)
    at MqttClient.emit (events.js:315:20)
    at MqttClient._handlePublish (/Volumes/SSD/Development/nestjs/lege-iot-nest/node_modules/[email protected]@mqtt/lib/client.js:1271:12)
    at MqttClient._handlePacket (/Volumes/SSD/Development/nestjs/lege-iot-nest/node_modules/[email protected]@mqtt/lib/client.js:410:12)
    at work (/Volumes/SSD/Development/nestjs/lege-iot-nest/node_modules/[email protected]@mqtt/lib/client.js:321:12)
    at Writable.writable._write (/Volumes/SSD/Development/nestjs/lege-iot-nest/node_modules/[email protected]@mqtt/lib/client.js:335:5)
    at doWrite (/Volumes/SSD/Development/nestjs/lege-iot-nest/node_modules/[email protected]@readable-stream/lib/_stream_writable.js:428:64)
    at writeOrBuffer (/Volumes/SSD/Development/nestjs/lege-iot-nest/node_modules/[email protected]@readable-stream/lib/_stream_writable.js:417:5)
    at Writable.write (/Volumes/SSD/Development/nestjs/lege-iot-nest/node_modules/[email protected]@readable-stream/lib/_stream_writable.js:334:11)
    at Socket.ondata (_stream_readable.js:707:22)
    at Socket.emit (events.js:315:20)
    at addChunk (_stream_readable.js:296:12)
    at readableAddChunk (_stream_readable.js:272:9)
    at Socket.Readable.push (_stream_readable.js:213:10)
    at TCP.onStreamRead (internal/stream_base_commons.js:186:23)

Crypto-KK avatar Aug 20 '20 07:08 Crypto-KK