From 54268759492df88644e4279fdcc600214f922f43 Mon Sep 17 00:00:00 2001
From: Mohamed Bassem <me@mbassem.com>
Date: Mon, 24 Nov 2025 01:23:06 +0000
Subject: feat: Introduce groupId in restate queue (#2168)

* feat: Introduce groupId in restate queue

* add group ids to the interface

* use last served timestamp
---
 packages/plugins/queue-restate/src/index.ts | 2 ++
 1 file changed, 2 insertions(+)

(limited to 'packages/plugins/queue-restate/src/index.ts')

diff --git a/packages/plugins/queue-restate/src/index.ts b/packages/plugins/queue-restate/src/index.ts
index 98668872..de37bbea 100644
--- a/packages/plugins/queue-restate/src/index.ts
+++ b/packages/plugins/queue-restate/src/index.ts
@@ -41,6 +41,7 @@ class RestateQueueWrapper<T> implements Queue<T> {
         data: {
           payload: T;
           priority: number;
+          groupId?: string;
         },
       ) => Promise<void>;
     }
@@ -49,6 +50,7 @@ class RestateQueueWrapper<T> implements Queue<T> {
       {
         payload,
         priority: options?.priority ?? 0,
+        groupId: options?.groupId,
       },
       restateClient.rpc.sendOpts({
         delay: options?.delayMs
-- 
cgit v1.2.3-70-g09d2