diff --git a/lib/RealTimeAPI.d.ts b/lib/RealTimeAPI.d.ts
index d7f9d27..383d3e1 100644
--- a/lib/RealTimeAPI.d.ts
+++ b/lib/RealTimeAPI.d.ts
@@ -72,5 +72,5 @@ export declare class RealTimeAPI {
     /**
      * getSubscription
      */
-    getSubscription(streamName: string, streamParam: string, addEvent: boolean): import("rxjs/internal/Observable").Observable<any>;
+    getSubscription(streamName: string, streamParam: any, addEvent: boolean): import("rxjs/internal/Observable").Observable<any>;
 }
diff --git a/lib/RealTimeAPI.js b/lib/RealTimeAPI.js
index 00a0cfb..2872b4e 100644
--- a/lib/RealTimeAPI.js
+++ b/lib/RealTimeAPI.js
@@ -184,14 +184,14 @@ var RealTimeAPI = /** @class */ (function () {
             msg: "sub",
             id: id,
             name: streamName,
-            params: [streamParam, addEvent]
+            params: streamParam//, addEvent]
         }); }, function () { return ({
             msg: "unsub",
             id: id
         }); }, function (message) {
-            return typeof message.collection === "string" &&
-                message.collection === streamName &&
-                message.fields.eventName === streamParam;
+              return typeof message.collection === "string" &&
+                message.collection === streamName 
+           // && message.fields.eventName === streamParam;
         } // Proper Filtering to be done. This is temporary filter just for the stream-room-messages subscription
         );
         return subscription;
@@ -199,4 +199,4 @@ var RealTimeAPI = /** @class */ (function () {
     return RealTimeAPI;
 }());
 exports.RealTimeAPI = RealTimeAPI;
-//# sourceMappingURL=RealTimeAPI.js.map
\ No newline at end of file
+//# sourceMappingURL=RealTimeAPI.js.map