From 47ab0524a84dfcff4b9e509b0a126cdd222de92d Mon Sep 17 00:00:00 2001
From: DarshanDodal <darshan.dodal@gmail.com>
Date: Mon, 1 Jan 2024 18:05:29 +0530
Subject: [PATCH] Topic information added

---
 packages/pubsub/src/Providers/MqttOverWS.ts | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/packages/pubsub/src/Providers/MqttOverWS.ts b/packages/pubsub/src/Providers/MqttOverWS.ts
index ea943b88bbb..2f14bcccb8c 100644
--- a/packages/pubsub/src/Providers/MqttOverWS.ts
+++ b/packages/pubsub/src/Providers/MqttOverWS.ts
@@ -290,7 +290,7 @@ export class MqttOverWS extends AbstractPubSub<MqttOptions> {
 			}
 
 			matchedTopicObservers.forEach(observersForTopic => {
-				observersForTopic.forEach(observer => observer.next(parsedMessage));
+				observersForTopic.forEach(observer => observer.next({topic:topic,msg:parsedMessage}));
 			});
 		} catch (error) {
 			logger.warn('Error handling message', error, msg);