diff --git a/src/proxy/topic/ReliableTopicListenerRunner.ts b/src/proxy/topic/ReliableTopicListenerRunner.ts index 8ca8210bb..76e8351bb 100644 --- a/src/proxy/topic/ReliableTopicListenerRunner.ts +++ b/src/proxy/topic/ReliableTopicListenerRunner.ts @@ -90,7 +90,7 @@ export class ReliableTopicListenerRunner { }) .catch((err) => { if (this.handleInternalError(err)) { - this.next(); + setImmediate(this.next.bind(this)); } else { this.proxy.removeMessageListener(this.listenerId); }