diff --git a/src/api/app_state.rs b/src/api/app_state.rs
index 712fe51..f02947d 100644
--- a/src/api/app_state.rs
+++ b/src/api/app_state.rs
@@ -1,5 +1,9 @@
 use super::config::Config;
-use crate::{db::connect_to_database, storage::s3::create_s3_client, workers};
+use crate::{
+    db::connect_to_database,
+    storage::s3::create_s3_client,
+    workers::{self, events::PRIMARY_STREAM},
+};
 use sqlx::PgPool;
 
 /// Shared state available to the API
@@ -22,7 +26,7 @@ impl AppState {
 
         // Connect to the job queue
         let nats_client = workers::create_nats_client().await?;
-        let jq_name = "FARMHAND_JOBS".to_string();
+        let jq_name = PRIMARY_STREAM.to_string();
         let job_queue = workers::Queue::connect(jq_name, nats_client)
             .await
             .expect("Failed to create worker queue");
diff --git a/src/bin/stream_listener.rs b/src/bin/stream_listener.rs
index 1651b6c..1db906e 100644
--- a/src/bin/stream_listener.rs
+++ b/src/bin/stream_listener.rs
@@ -2,7 +2,10 @@
 //! It intentionally does not do anything else
 
 use anyhow::Result;
-use farmhand::workers::{self, events::EVENT_PREFIX};
+use farmhand::workers::{
+    self,
+    events::{EVENT_PREFIX, PRIMARY_STREAM},
+};
 use futures::StreamExt;
 use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt};
 
@@ -21,7 +24,7 @@ async fn main() -> Result<()> {
     // Setup the Jetstream queue
     let jq_name = std::env::args()
         .nth(1)
-        .unwrap_or_else(|| "FARMHAND_JOBS".to_string());
+        .unwrap_or_else(|| PRIMARY_STREAM.to_string());
     let queue = workers::Queue::connect(jq_name, nats_client)
         .await
         .expect("Failed to create worker queue");