pgmq 0.34.0-alpha.5

A distributed message queue for Rust applications, on Postgres.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13

//! Shared SQL query strings.

// Note: the `language=PostgreSQL` comment allows JetBrains IDEs to provide inline syntax
// highlighting for the string content. See: https://www.jetbrains.com/help/idea/using-language-injections.html#use-language-injection-comments

// language=PostgreSQL
pub const CREATE: &str = "SELECT pgmq.create(queue_name=>$1::text)";

// language=PostgreSQL
pub const SEND: &str = "SELECT * FROM pgmq.send(queue_name=>$1::text, msg=>$2::jsonb, headers=>$3::jsonb, delay=>$4::int)";

// language=PostgreSQL
pub const READ: &str = r"SELECT msg_id, read_ct, enqueued_at, last_read_at, vt, message, headers FROM pgmq.read(queue_name=>$1::text, vt=>$2::integer, qty=>$3::integer)";