diff --git a/Cargo.lock b/Cargo.lock index 6ac25080..4e324e45 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -1243,10 +1243,10 @@ dependencies = [ [[package]] name = "pgmq" -version = "0.11.1" +version = "0.11.2" dependencies = [ "chrono", - "pgmq 0.14.3", + "pgmq 0.14.4", "pgrx", "pgrx-tests", "rand", @@ -1260,7 +1260,7 @@ dependencies = [ [[package]] name = "pgmq" -version = "0.14.3" +version = "0.14.4" dependencies = [ "chrono", "log", diff --git a/Cargo.toml b/Cargo.toml index 52bb1fef..25b186bc 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "pgmq" -version = "0.11.1" +version = "0.11.2" edition = "2021" authors = ["Tembo.io"] description = "Postgres extension for PGMQ" diff --git a/core/Cargo.toml b/core/Cargo.toml index edba5d92..8bb290ee 100644 --- a/core/Cargo.toml +++ b/core/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "pgmq" -version = "0.14.3" +version = "0.14.4" edition = "2021" authors = ["Tembo.io"] description = "A distributed message queue for Rust applications, on Postgres." diff --git a/core/src/query.rs b/core/src/query.rs index c7410f0a..22b7bd95 100644 --- a/core/src/query.rs +++ b/core/src/query.rs @@ -183,9 +183,7 @@ pub fn enqueue( check_input(name)?; let mut values = "".to_owned(); for message in messages.iter() { - let full_msg = format!( - "((now() + interval '{delay} seconds'), '{message}'::json)," - ); + let full_msg = format!("((now() + interval '{delay} seconds'), '{message}'::json),"); values.push_str(&full_msg) } // drop trailing comma from constructed string