Skip to content

Commit b0a2c42

Browse files
committed
Add some additional logging around nacking messages
1 parent cac3c32 commit b0a2c42

File tree

1 file changed

+15
-0
lines changed

1 file changed

+15
-0
lines changed

apps/webapp/app/v3/marqs/sharedQueueConsumer.server.ts

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -411,11 +411,21 @@ export class SharedQueueConsumer {
411411
});
412412

413413
if (!queue) {
414+
logger.debug("SharedQueueConsumer queue not found, so nacking message", {
415+
queueMessage: message,
416+
taskRunQueue: lockedTaskRun.queue,
417+
runtimeEnvironmentId: lockedTaskRun.runtimeEnvironmentId,
418+
});
419+
414420
await this.#nackAndDoMoreWork(message.messageId, this._options.nextTickInterval);
415421
return;
416422
}
417423

418424
if (!this._enabled) {
425+
logger.debug("SharedQueueConsumer not enabled, so nacking message", {
426+
queueMessage: message,
427+
});
428+
419429
await marqs?.nackMessage(message.messageId);
420430
return;
421431
}
@@ -521,6 +531,11 @@ export class SharedQueueConsumer {
521531
}),
522532
]);
523533

534+
logger.error("SharedQueueConsumer errored, so nacking message", {
535+
queueMessage: message,
536+
error: e instanceof Error ? { name: e.name, message: e.message, stack: e.stack } : e,
537+
});
538+
524539
await this.#nackAndDoMoreWork(message.messageId);
525540
return;
526541
}

0 commit comments

Comments
 (0)