stop heartbeat timeout on non-inplace replace message

2024-05-03 14:19:08 +01:00
parent 1286147ea8
commit 30b6c2c35e
1 changed files with 2 additions and 0 deletions
@@ -458,6 +458,8 @@ export class MarQS {
          return;
        }

+        workerQueue.dequeue(`requeueTaskRun:${messageId}`);
+
        await this.#callAcknowledgeMessage({
          parentQueue: oldMessage.parentQueue,
          messageKey: this.keys.messageKey(messageId),