From f3c980d48a7e3395ba5edbd14440192fa181cc65 Mon Sep 17 00:00:00 2001
From: Kevin Keyt <kevinkeyt@gmail.com>
Date: Mon, 18 Nov 2024 15:27:41 -0500
Subject: [PATCH] Update for Issue #68

---
 src/lib/broker/queue.ts | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/lib/broker/queue.ts b/src/lib/broker/queue.ts
index 7beef10..f7802f6 100644
--- 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