Defer AMQP delayed queue pruning

dahlia · dahlia · commit 07d70b2782a4 · 2026-05-02T16:15:58.000+09:00
Keep AMQP delayed queue tracking cheap on enqueue by recording the expiry without scanning the whole map. Stale delayed queue names are still pruned before getDepth() probes them. #748 (comment) Assisted-by: Codex:gpt-5.5
diff --git a/packages/amqp/src/mq.ts b/packages/amqp/src/mq.ts
@@ -372,7 +372,6 @@ export class AmqpMessageQueue implements MessageQueue {
 
   #trackDelayedQueue(queue: string, delay: number): void {
     this.#delayedQueues.set(queue, Date.now() + Math.max(0, delay) + 60_000);
-    this.#pruneDelayedQueues();
   }
 
   #pruneDelayedQueues(): void {

Original file line number	Diff line number	Diff line change
`@@ -372,7 +372,6 @@ export class AmqpMessageQueue implements MessageQueue {`
`372`	`372`
`373`	`373`	`#trackDelayedQueue(queue: string, delay: number): void {`
`374`	`374`	`this.#delayedQueues.set(queue, Date.now() + Math.max(0, delay) + 60_000);`
`375`		`- this.#pruneDelayedQueues();`
`376`	`375`	`}`
`377`	`376`
`378`	`377`	`#pruneDelayedQueues(): void {`