Schedule task requeue when dequeueing message in shared queue

nicktrn · nicktrn · commit 58b6b1aa0d98 · 2024-06-04T11:02:15.000+01:00
diff --git a/apps/webapp/app/v3/marqs/index.server.ts b/apps/webapp/app/v3/marqs/index.server.ts
@@ -361,6 +361,11 @@ export class MarQS {
           });
         }
 
+        await RequeueTaskRunService.enqueue(
+          messageData.messageId,
+          new Date(Date.now() + this.visibilityTimeoutInMs)
+        );
+
         return message;
       },
       {

Original file line number	Diff line number	Diff line change
`@@ -361,6 +361,11 @@ export class MarQS {`
`361`	`361`	`});`
`362`	`362`	`}`
`363`	`363`
	`364`	`+ await RequeueTaskRunService.enqueue(`
	`365`	`+ messageData.messageId,`
	`366`	`+ new Date(Date.now() + this.visibilityTimeoutInMs)`
	`367`	`+ );`
	`368`	`+`
`364`	`369`	`return message;`
`365`	`370`	`},`
`366`	`371`	`{`