diff --git a/src/com/moclojer/rq/adapters.clj b/src/com/moclojer/rq/adapters.clj
index e945d25..618e46f 100644
--- a/src/com/moclojer/rq/adapters.clj
+++ b/src/com/moclojer/rq/adapters.clj
@@ -2,6 +2,7 @@
   (:require
    [clojure.data.json :as json]
    [clojure.edn :as edn]
+   [clojure.string :as str]
    [clojure.tools.logging :as log])
   (:import
    [redis.clients.jedis.args ListPosition]))
@@ -30,7 +31,14 @@
 (defn unpack-pattern
   [pattern queue-name]
   (log/debug :unpacking pattern queue-name)
-  (subs queue-name (count (pattern->str pattern))))
+  (let [prefix (pattern->str pattern)]
+    (if (str/starts-with? queue-name prefix)
+      (subs queue-name (count prefix))
+      (do
+        (log/warn :invalid-prefix
+                  :queue-name queue-name
+                  :expected-prefix prefix)
+        queue-name))))
 
 (def encoding-fns
   {:none identity