Class SqlOutbox

Checks the adapter capabilities and prefix without creating tables.

Enqueues once per delivery id, refusing new content behind the run's fence (a mail delivery is content).

Lists pending deliveries due at now, ordered by due time and id; a mail delivery past its expiry is left out.

Marks a delivery accepted by its destination; a mail's body goes with it, so it outlives no pending delivery.

Advances retry backoff, giving up a day after the first failed attempt. A delivery no longer pending (delivered, or given up) is left as it is.

Resets attempts and makes a delivery due now without restoring any purged payload; a mail delivery is never replayed.

Ends a pending delivery at once, a mail's body emptied; one no longer pending is left as it is.

Moves a pending delivery's next attempt to notBefore, never earlier than it is, without counting an attempt.

Ends every pending delivery of the run to the destination, their mail bodies emptied.

Ends every pending mail delivery whose expiry has passed, dead with its body emptied; the count ended.

Fences new content and scrubs content deliveries, including delivered rows; content-free deliveries keep their type and payload. A send of the run that sendClaimed has under way in this process and that has not written its body yet stops.

Lists all deliveries of a run, including delivered and dead ones.

Sends one delivery as the table holds it now, not as due returned it: one gone or no longer pending is skipped (false). The signal send gets aborts when this outbox's purgeContent purges the delivery's run, so a send that has not written its body yet stops (false); any other rejection is send's. A purge committed through another instance or process reaches a send only through the re-read, so the manager that purges and the dispatcher take the same SqlOutbox.