Variable sweepDeadLetters

Type Declaration

• • (
        nowMs?: any,
    ): {
        byCode: unknown[];
        byStream: unknown[];
        expired: number;
        held: unknown;
        letters: any;
        orphaned: number;
        trimmed: any;
    }

  • Sweeps the ambient realm's dead letters: deletes those older than ssf.deadLetterRetentionS or belonging to no stream, enforces the per-stream cap, rebuilds the counts, and hands back and resets what was dead-lettered since the last sweep.

    Parameters

    • OptionalnowMs: any

      the current time, for tests

    Returns {
        byCode: unknown[];
        byStream: unknown[];
        expired: number;
        held: unknown;
        letters: any;
        orphaned: number;
        trimmed: any;
    }

    the sweep's summary: held, letters, expired, orphaned, trimmed and the counts by error code