diff --git a/Cargo.lock b/Cargo.lock
index 185b1a84..dc63bb9b 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -1240,10 +1240,10 @@ dependencies = [
 
 [[package]]
 name = "pgmq"
-version = "0.10.1"
+version = "0.10.2"
 dependencies = [
  "chrono",
- "pgmq 0.13.1",
+ "pgmq 0.14.0",
  "pgrx",
  "pgrx-tests",
  "rand",
@@ -1257,7 +1257,7 @@ dependencies = [
 
 [[package]]
 name = "pgmq"
-version = "0.13.1"
+version = "0.14.0"
 dependencies = [
  "chrono",
  "log",
diff --git a/Cargo.toml b/Cargo.toml
index de699892..3996c22a 100644
--- 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
index 6efdfc89..21c88706 100644
--- a/src/lib.rs
+++ b/src/lib.rs
@@ -10,7 +10,7 @@ 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, TABLE_PREFIX, PGMQ_SCHEMA};
 use thiserror::Error;
 
 #[derive(Error, Debug)]
@@ -82,7 +82,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;
         "