Crate fx_mq_jobs 

Structs

LeaseRenewer

Secure wrapper for renewing message leases during processing.

Listener

Job listener that coordinates workers and database polling.

PgIdentifier

Publisher

Service for publishing typed messages to the job queue.

Queries

RegistryBuilder

Builder for creating a registry with typed handlers.

RegistryError

Error returned when no handler is registered for a message type.

Enums

LeaseRenewalError

Error returned when lease renewal fails.

MigratorError

PgIdentifierParsingError

PublishError

Constants

FX_MQ_JOBS_SCHEMA_NAME

Traits

Handler

Trait for processing typed messages with retry logic.

Message

Functions

run_migrations

Runs database migrations for the specified schema.