diff --git a/lib/queue/processor.py b/lib/queue/processor.py
index 089900c..494cb9b 100644
--- a/lib/queue/processor.py
+++ b/lib/queue/processor.py
@@ -14,7 +14,8 @@ def create(cls, input_queue_name: str = None, batch_size: int = 10):
         Instantiate a queue. Must pass input_queue_name, output_queue_name, and batch_size.
         Pulls settings and then inits instance.
         """
-        input_queue_name = get_setting(input_queue_name, "MODEL_NAME").replace(".", "__")
+        queue_prefix = get_setting("", "QUEUE_PREFIX").replace(".", "__")
+        input_queue_name = queue_prefix+get_setting(input_queue_name, "MODEL_NAME").replace(".", "__")
         logger.info(f"Starting queue with: ('{input_queue_name}', {batch_size})")
         return QueueProcessor(input_queue_name, batch_size)