Skip to content

Commit b18d4fe

Browse files
committed
review fix
1 parent e7de1bb commit b18d4fe

File tree

1 file changed

+3
-4
lines changed
  • packages/cloudflare/src/api/durable-objects

1 file changed

+3
-4
lines changed

packages/cloudflare/src/api/durable-objects/queue.ts

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -142,18 +142,17 @@ export class DurableObjectQueueHandler extends DurableObject<CloudflareEnv> {
142142
this.routeInFailedState.delete(msg.MessageDeduplicationId);
143143
return;
144144
}
145-
const nextAlarm = Date.now() + Math.pow(2, existingFailedState.retryCount + 1) * 2_000;
145+
const nextAlarmMs = Date.now() + Math.pow(2, existingFailedState.retryCount + 1) * 2_000;
146146
this.routeInFailedState.set(msg.MessageDeduplicationId, {
147147
...existingFailedState,
148148
retryCount: existingFailedState.retryCount + 1,
149-
nextAlarmMs: nextAlarm,
149+
nextAlarmMs,
150150
});
151151
} else {
152-
const nextAlarm = Date.now() + 2_000;
153152
this.routeInFailedState.set(msg.MessageDeduplicationId, {
154153
msg,
155154
retryCount: 1,
156-
nextAlarmMs: nextAlarm,
155+
nextAlarmMs: Date.now() + 2_000,
157156
});
158157
}
159158
// We probably want to do something if routeInFailedState is becoming too big, at least log it

0 commit comments

Comments
 (0)