From da7dd052cb3c064b2ad1d0d95c9b28e51bc47089 Mon Sep 17 00:00:00 2001
From: souvik <souvikde.ns@gmail.com>
Date: Wed, 22 Nov 2023 18:04:15 +0530
Subject: [PATCH] Update index.ts

---
 src/adapters/mqtt/index.ts | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/adapters/mqtt/index.ts b/src/adapters/mqtt/index.ts
index 268da2f84..069eb2f1f 100644
--- 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,
     })
   }