Struct Queue 

pub struct Queue;

Global handle to the queue’s database connection.

Initialise once at application start with Queue::init; worker loops and dispatcher call Queue::connection to get the static reference.

Implementations

impl Queue

pub fn connection() -> &'static DatabaseConnection

Return a reference to the global DatabaseConnection.

Panics

Panics if Queue::init has not been called yet.

pub async fn init(conn: DatabaseConnection) -> Result<(), Error>

Store conn as the global connection.

Returns Err if called more than once.

pub fn is_initialized() -> bool

Returns true if Queue::init has been called.

pub fn register<J>()

where J: Job + DeserializeOwned + 'static,

Register a job type for auto-start by the framework’s WorkerLoop.

Call this in your application bootstrap before the server starts. The framework’s server boot path inspects Queue::has_registered_jobs and spawns a WorkerLoop automatically when at least one type is registered.

pub fn has_registered_jobs() -> bool

Returns true if at least one job type has been registered via Queue::register.