nest-mqtt
nest-mqtt copied to clipboard
Tried to publish but returned TypeError: this.mqttService.publish is not a function
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)