diff --git a/listener/src/config.ts b/listener/src/config.ts index 1100a8c..77098e3 100644 --- a/listener/src/config.ts +++ b/listener/src/config.ts @@ -164,6 +164,7 @@ export function loadConfig(): Config { maxRetries: parseIntegerEnv('RETRY_MAX_RETRIES', '5'), multiplier: parseIntegerEnv('RETRY_MULTIPLIER', '2'), jitter: trimEnv('RETRY_JITTER') !== 'false', + processIntervalMs: parseIntegerEnv('RETRY_QUEUE_PROCESS_INTERVAL_MS', '5000'), }, eventQueue: { maxConcurrency: parseIntegerEnv('EVENT_QUEUE_MAX_CONCURRENCY', '1'), diff --git a/listener/src/types/index.ts b/listener/src/types/index.ts index df6ea07..42a08da 100644 --- a/listener/src/types/index.ts +++ b/listener/src/types/index.ts @@ -18,6 +18,7 @@ export interface RetryQueueConfig { multiplier?: number; jitter?: boolean; maxRetries?: number; + processIntervalMs?: number; } export interface WebhookSecret {