Module queue

Expand description

Queue row type, status enum, and retry-attempt bookkeeping.

Structs§

QueuedMessage: One queued outbound message — the full row stored in the outbound queue.

add_suppression: add a recipient to the suppression list after a hard bounce
cancel_pending: cancel a pending outbound message (undo send)
cancel_pending_by_message_id: cancel a pending outbound message by message_id (undo send)
dequeue: fetch pending messages ready for delivery
enqueue: enqueue a message for outbound delivery
enqueue_ex: enqueue a message for outbound delivery with forwarding flag
enqueue_scheduled: enqueue a message for scheduled delivery at a future time
get_message: get a specific queued message by id
is_hard_bounce: detect if an SMTP error is a permanent/hard bounce (5xx)
is_suppressed: check if a recipient address is in the suppression list (hard bounce)
list_recent: list recent queue entries for admin UI
list_suppressions: list all suppressed addresses
mark_bounced: mark a message as permanently bounced
mark_delivered: mark a message as delivered
mark_failed: mark a message as failed with next retry time
mark_inflight: mark a message as in-flight
notify: notify the delivery worker that new messages are queued
queue_stats: get queue statistics
recover_stale_inflight: recover messages stuck in inflight status for more than 10 minutes (worker crashed or was killed before marking them as delivered/failed)
remove_suppression: remove an address from the suppression list (admin override)
retry_message: reset a bounced/failed message back to pending for retry