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);