Update index.ts

Souvikns · Nov 22, 2023 · da7dd05 · da7dd05
1 parent 18729c4
commit da7dd05
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/adapters/mqtt/index.ts b/src/adapters/mqtt/index.ts
@@ -278,11 +278,11 @@ class MqttAdapter extends Adapter {
       dup: packet.dup,
       length: packet.length,
     }
-
+    const id = this.parsedAsyncAPI.channels().filter(channel => channel.address() === packet.topic)[0].id()
     return new GleeMessage({
       payload: packet.payload,
       headers,
-      channel: packet.topic,
+      channel: id,
     })
   }