diff --git a/apps/api/src/services/event-queue.ts b/apps/api/src/services/event-queue.ts index 5b71e3f..8c8ac28 100644 --- a/apps/api/src/services/event-queue.ts +++ b/apps/api/src/services/event-queue.ts @@ -46,6 +46,7 @@ function exponentialDelay(initialDelay: number, tries: number, cap: number = Inf } export class EventQueue>> { + private static readonly DEQUEUE_ALREADY_CLAIMED_SKIP_DELAY_MS = 250; private static readonly DEQUEUE_RETRY_DELAY_MS = secToMs(10); private static readonly DEQUEUE_RETRY_LIMIT = 3; private static readonly RATE_LIMIT_RETRY_LIMIT = 15; @@ -78,6 +79,7 @@ export class EventQueue