From bc0a9b5c588efcb81faefaca620b6d9b1f2e4e7e Mon Sep 17 00:00:00 2001 From: nico-kn Date: Tue, 9 Dec 2025 09:58:36 +0100 Subject: [PATCH] fix(WaitForProcessing): change entry condition --- src/subscriber.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/subscriber.ts b/src/subscriber.ts index c12996862..d4ec0cc15 100644 --- a/src/subscriber.ts +++ b/src/subscriber.ts @@ -1000,7 +1000,7 @@ export class Subscriber extends EventEmitter { const shutdownStart = Date.now(); if ( behavior === SubscriberCloseBehaviors.WaitForProcessing && - !this._inventory.isEmpty + !this._inventory.isEmpty() ) { const waitTimeout = timeout.subtract(FINAL_NACK_TIMEOUT);