pgmq 0.33.2

A distributed message queue for Rust applications, on Postgres.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

use pgmq::Message;
use serde::{Deserialize, Serialize};

#[derive(Serialize, Debug, Deserialize, Eq, PartialEq)]
struct MyMessage {
    foo: String,
    num: u64,
}

#[tokio::main]
async fn main() {
    let db_url = "postgres://postgres:postgres@localhost:5432/postgres".to_string();
    let queue = pgmq::PGMQueueExt::new(db_url, 2)
        .await
        .expect("failed to connect to postgres");

    // Installs the specific version from GitHub.
    queue.install_sql_from_github(Some("1.10.0")).await.unwrap();

    // Installs the version embedded in the rust crate. This may not always be the latest released
    // extension version.
    queue.install_sql_from_embedded().await.unwrap();

    // Installs the latest version from GitHub
    queue.install_sql_from_github(None).await.unwrap();

    queue
        .create("my_queue")
        .await
        .expect("failed to create queue");

    let msg = MyMessage {
        foo: "hello".to_string(),
        num: 42,
    };
    queue
        .send("my_queue", &msg)
        .await
        .expect("failed to send message");
    let received_struct_message: Message<MyMessage> = queue
        .read::<MyMessage>(&"my_queue", 15)
        .await
        .unwrap()
        .expect("No messages in the queue");
    println!("Received a message: {received_struct_message:?}");
}