@@ -569,13 +569,18 @@ class RetryQueue implements IQueue<QueueItemData> {
569
569
const firstAttemptedAt = inProgressItem ?. firstAttemptedAt ?? now ;
570
570
const lastAttemptedAt = inProgressItem ?. lastAttemptedAt ?? now ;
571
571
572
- // A decimal integer representing the seconds since the last attempt
572
+ // A decimal integer representing the seconds since the first attempt
573
573
const timeSinceFirstAttempt = Math . round ( ( now - firstAttemptedAt ) / 1000 ) ;
574
+
575
+ // A decimal integer representing the seconds since the last attempt
574
576
const timeSinceLastAttempt = Math . round ( ( now - lastAttemptedAt ) / 1000 ) ;
577
+
578
+ // Indicates if the item has been reclaimed from local storage
575
579
const reclaimed = inProgressItem ?. reclaimed ?? false ;
576
580
577
- // Update the last attempted at timestamp for the in progress item
581
+ // Update the first attempted at timestamp for the in progress item
578
582
inProgressItem . firstAttemptedAt = firstAttemptedAt ;
583
+ // Update the last attempted at to current timestamp for the in progress item
579
584
inProgressItem . lastAttemptedAt = now ;
580
585
581
586
inProgress [ el . id ] = inProgressItem ;
@@ -669,6 +674,7 @@ class RetryQueue implements IQueue<QueueItemData> {
669
674
type : el . type ?? type ,
670
675
firstAttemptedAt : el . firstAttemptedAt ,
671
676
lastAttemptedAt : el . lastAttemptedAt ,
677
+ // Mark the item as reclaimed from local storage
672
678
reclaimed : true ,
673
679
} ) ;
674
680
trackMessageIds . push ( id ) ;
@@ -695,6 +701,7 @@ class RetryQueue implements IQueue<QueueItemData> {
695
701
this . enqueue ( {
696
702
...el ,
697
703
id,
704
+ // Mark the item as reclaimed from local storage
698
705
reclaimed : true ,
699
706
type : el . type ?? SINGLE_QUEUE_ITEM_TYPE ,
700
707
time : this . schedule . now ( ) ,
0 commit comments