Fix leak in ReliableTopicListenerRunner.next (#1377) (#1381)

hazelcast · Oct 3, 2022 · d5ccb4b · d5ccb4b
1 parent 2f96cbb
commit d5ccb4b
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);
                 }