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 87366af commit f1d56c6Copy full SHA for f1d56c6
packages/redis-worker/src/queue.ts
@@ -318,6 +318,12 @@ export class SimpleQueue<TMessageCatalog extends MessageCatalogSchema> {
318
319
async moveToDeadLetterQueue(id: string, errorMessage: string): Promise<void> {
320
try {
321
+ this.logger.debug(`SimpleQueue ${this.name}.moveToDeadLetterQueue(): moving item to DLQ`, {
322
+ queue: this.name,
323
+ id,
324
+ errorMessage,
325
+ });
326
+
327
const result = await this.redis.moveToDeadLetterQueue(
328
`queue`,
329
`items`,
0 commit comments