fix(restate): Fix priority for restate queue

1 files changed, 6 insertions, 5 deletions

diff --git a/packages/plugins-queue-restate/src/semaphore.ts b/packages/plugins-queue-restate/src/semaphore.ts
index eb78f6b6..ad636f98 100644
--- a/packages/plugins-queue-restate/src/semaphore.ts
+++ b/packages/plugins-queue-restate/src/semaphore.ts
@@ -46,15 +46,16 @@ export const semaphore = object({
   },
 });
 
+// Lower numbers represent higher priority, mirroring Liteque’s semantics.
 function selectAndPopItem(items: QueueItem[]): QueueItem {
-  let highest = { priority: Number.MIN_SAFE_INTEGER, index: 0 };
+  let selected = { priority: Number.MAX_SAFE_INTEGER, index: 0 };
   for (const [i, item] of items.entries()) {
-    if (item.priority > highest.priority) {
-      highest.priority = item.priority;
-      highest.index = i;
+    if (item.priority < selected.priority) {
+      selected.priority = item.priority;
+      selected.index = i;
     }
   }
-  const [item] = items.splice(highest.index, 1);
+  const [item] = items.splice(selected.index, 1);
   return item;
 }