fully qualify insert path (#21)

* fully qualiy insert path * fmt
tembo-io · Aug 6, 2023 · 440b504 · 440b504
1 parent 562fd94
commit 440b504
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 6 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "pgmq"
-version = "0.10.1"
+version = "0.10.2"
 edition = "2021"
 authors = ["Tembo.io"]
 description = "Postgres extension for PGMQ"

diff --git a/src/lib.rs b/src/lib.rs
@@ -10,7 +10,9 @@ pub mod metrics;
 pub mod partition;
 
 use pgmq_crate::errors::PgmqError;
-use pgmq_crate::query::{archive, check_input, delete, init_queue, pop, read, TABLE_PREFIX};
+use pgmq_crate::query::{
+    archive, check_input, delete, init_queue, pop, read, PGMQ_SCHEMA, TABLE_PREFIX,
+};
 use thiserror::Error;
 
 #[derive(Error, Debug)]
@@ -82,7 +84,7 @@ fn enqueue_str(name: &str) -> Result<String, PgmqError> {
     check_input(name)?;
     Ok(format!(
         "
-        INSERT INTO {TABLE_PREFIX}_{name} (vt, message)
+        INSERT INTO {PGMQ_SCHEMA}.{TABLE_PREFIX}_{name} (vt, message)
         VALUES (now() at time zone 'utc', $1)
         RETURNING msg_id;
         "