Call subscriber.messageDequeued in dequeueMessageInSharedQueue

matt-aitken · matt-aitken · commit 6b0c37ae6d37 · 2024-08-15T10:10:53.000+01:00
diff --git a/apps/webapp/app/v3/marqs/index.server.ts b/apps/webapp/app/v3/marqs/index.server.ts
@@ -386,6 +386,8 @@ export class MarQS {
             [SemanticAttributes.CONCURRENCY_KEY]: message.concurrencyKey,
             [SemanticAttributes.PARENT_QUEUE]: message.parentQueue,
           });
+
+          await this.options.subscriber?.messageDequeued(message);
         }
 
         await this.options.visibilityTimeoutStrategy.heartbeat(

Original file line number	Diff line number	Diff line change
`@@ -386,6 +386,8 @@ export class MarQS {`
`386`	`386`	`[SemanticAttributes.CONCURRENCY_KEY]: message.concurrencyKey,`
`387`	`387`	`[SemanticAttributes.PARENT_QUEUE]: message.parentQueue,`
`388`	`388`	`});`
	`389`	`+`
	`390`	`+ await this.options.subscriber?.messageDequeued(message);`
`389`	`391`	`}`
`390`	`392`
`391`	`393`	`await this.options.visibilityTimeoutStrategy.heartbeat(`