diff --git a/lib/index.js b/lib/index.js index fd225e5..c753c4a 100644 --- a/lib/index.js +++ b/lib/index.js @@ -5458,7 +5458,6 @@ class MqttMsgClient extends MessageClient { this.emit('error', error); }); this.cli.on('message', (topic, message) => { - console.debug('MQTT 收到消息', topic, message); const handle = this.subMsgHandler.get(topic); if (handle) { if (this.options.protocol === 'json') { diff --git a/src/message/MqttBroker.ts b/src/message/MqttBroker.ts index 141afcc..c687141 100644 --- a/src/message/MqttBroker.ts +++ b/src/message/MqttBroker.ts @@ -52,7 +52,6 @@ export class MqttMsgClient extends MessageClient { this.emit('error', error); }); this.cli.on('message', (topic, message) => { - console.debug('MQTT 收到消息', topic, message); const handle = this.subMsgHandler.get(topic); if (handle) { if (this.options.protocol === 'json') {