fix: use channel.address instead of id

Souvikns · Nov 17, 2023 · a6a542f · a6a542f
1 parent 822268f
commit a6a542f
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/src/adapters/mqtt/index.ts b/src/adapters/mqtt/index.ts
@@ -110,7 +110,7 @@ class MqttAdapter extends Adapter {
     this.client.on('close', () => {
       this.emit('close', {
         connection: this.client,
-        channels: this.channelNames,
+        channels: this.channelAddresses,
       })
     })
 
@@ -140,7 +140,6 @@ class MqttAdapter extends Adapter {
   private subscribe(channels: string[]) {
     channels.forEach((channel) => {
       const binding = this.parsedAsyncAPI.channels().get(channel).bindings().get('mqtt')?.value()
-      console.log(binding)
       this.client.subscribe(channel, {
         qos: binding?.qos ? binding.qos : 0,
       }, (err, granted) => {
@@ -255,7 +254,6 @@ class MqttAdapter extends Adapter {
 
   _customAckHandler(channel, message, mqttPacket, done) {
     const msg = this._createMessage(mqttPacket as IPublishPacket)
-    console.log('Hello World')
 
     msg.on('processing:successful', () => done(MQTT_SUCCESS_REASON))
     msg.on('processing:failed', () => done(MQTT_UNSPECIFIED_ERROR_REASON))