Member Junction
    Preparing search index...

    The publish deduplication ledger (03 §2.1, F1), shared by every transport. Construct it over a transaction (Database publishes) or an independent executor (cloud publishes) — never over the shared source executor (03 §11). A reservation proves a send was attempted, not that it succeeded: a process that dies between reserve and send must not turn the caller's retry into a silent success, so only a Confirmed row is a duplicate.

    Index

    Constructors

    Methods

    • Parameters

      • topicID: string
      • key: string
      • messageID: string
      • ttlSeconds: number

      Returns Promise<boolean>

    • Deletes expired keys in batches until a batch comes back short or maxBatches is reached.

      Parameters

      • batchSize: number = 1000
      • maxBatches: number = 20

      Returns Promise<number>