Fix leak in ReliableTopicListenerRunner.next (hazelcast#1377)

srknzl · Sep 30, 2022 · 889a54d · 889a54d
1 parent 2f96cbb
commit 889a54d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/proxy/topic/ReliableTopicListenerRunner.ts b/src/proxy/topic/ReliableTopicListenerRunner.ts
@@ -90,7 +90,7 @@ export class ReliableTopicListenerRunner<E> {
             })
             .catch((err) => {
                 if (this.handleInternalError(err)) {
-                    this.next();
+                    setImmediate(this.next.bind(this));
                 } else {
                     this.proxy.removeMessageListener(this.listenerId);
                 }