Skip to main content

enqueue

Function enqueue 

Source
pub fn enqueue() -> EnqueueBuilder<'static, ()>
Expand description

Start an enqueue operation.

let store = pgqrs::connect("postgresql://localhost/mydb").await?;
let ids = pgqrs::enqueue()
    .message(&json!({"task": "send_email"}))
    .to("tasks")
    .execute(&store)
    .await?;