Update for Issue mxsdev#68

kevinkeyt · Nov 18, 2024 · f3c980d · f3c980d
1 parent 4899dc1
commit f3c980d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/lib/broker/queue.ts b/src/lib/broker/queue.ts
@@ -616,8 +616,8 @@ export abstract class MessageSequence<M extends TaggedMessage> {
         }, lockDurationMs),
       })
 
-      message.message_annotations[Constants.lockedUntil] =
-        +new Date().getTime() + lockDurationMs
+      const locked_until = +Date.now() + lockDurationMs
+      message.message_annotations[Constants.lockedUntil] = new Date(locked_until)
 
       // TODO: set drained based on whether there are more messages to send