diff --git a/packages/sdk/src/protocols/filter/index.ts b/packages/sdk/src/protocols/filter/index.ts
index b57dfad394..3e34b6fc59 100644
--- a/packages/sdk/src/protocols/filter/index.ts
+++ b/packages/sdk/src/protocols/filter/index.ts
@@ -27,6 +27,7 @@ import {
 } from "@waku/utils";
 
 import { BaseProtocolSDK } from "../base_protocol";
+import { MessageReliabilityMonitor } from "../message_reliability_monitor";
 
 import { SubscriptionManager } from "./subscription_manager";
 
@@ -203,9 +204,9 @@ class FilterSDK extends BaseProtocolSDK implements IFilterSDK {
       this.connectedPeers.map((peer) => peer.id.toString())
     );
 
-    const subscription =
-      this.getActiveSubscription(pubsubTopic) ??
-      this.setActiveSubscription(
+    let subscription = this.getActiveSubscription(pubsubTopic);
+    if (!subscription) {
+      subscription = this.setActiveSubscription(
         pubsubTopic,
         new SubscriptionManager(
           pubsubTopic,
@@ -216,6 +217,9 @@ class FilterSDK extends BaseProtocolSDK implements IFilterSDK {
         )
       );
 
+      new MessageReliabilityMonitor(this, subscription);
+    }
+
     return {
       error: null,
       subscription
diff --git a/packages/sdk/src/waku.ts b/packages/sdk/src/waku.ts
index 1aa3cf1f18..de5452cf8e 100644
--- a/packages/sdk/src/waku.ts
+++ b/packages/sdk/src/waku.ts
@@ -18,7 +18,7 @@ import { Logger } from "@waku/utils";
 
 import { wakuFilter } from "./protocols/filter/index.js";
 import { wakuLightPush } from "./protocols/light_push.js";
-import { MessageReliabilityMonitor } from "./protocols/message_reliability_monitor.js";
+import { MessageReliabilityManager } from "./protocols/message_reliability_monitor.js";
 import { wakuStore } from "./protocols/store.js";
 
 export const DefaultPingKeepAliveValueSecs = 5 * 60;
@@ -116,7 +116,7 @@ export class WakuNode implements Waku {
     if (protocolsEnabled.filter) {
       const filter = wakuFilter(this.connectionManager);
       this.filter = filter(libp2p);
-      new MessageReliabilityMonitor(this.filter);
+      new MessageReliabilityManager(this.filter);
     }
 
     log.info(