We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e8a5785 commit 92d53f8Copy full SHA for 92d53f8
apps/webapp/app/v3/marqs/v2.server.ts
@@ -20,6 +20,10 @@ const KEY_PREFIX = "marqsv2:";
20
const SHARED_QUEUE_NAME = "sharedQueue";
21
22
export class V2VisibilityTimeout implements VisibilityTimeoutStrategy {
23
+ async startHeartbeat(messageId: string, timeoutInMs: number): Promise<void> {
24
+ RequeueV2Message.enqueue(messageId, new Date(Date.now() + timeoutInMs));
25
+ }
26
+
27
async heartbeat(messageId: string, timeoutInMs: number): Promise<void> {
28
RequeueV2Message.enqueue(messageId, new Date(Date.now() + timeoutInMs));
29
}
0 commit comments