From 9053712773c8b5854a623b3fa04efadebbf9a2ff Mon Sep 17 00:00:00 2001
From: David House <davidahouse@gmail.com>
Date: Tue, 12 Nov 2019 15:34:55 -0500
Subject: [PATCH] :recycle: Standardize on the queue naming

---
 bin/stampede-worker.js | 13 ++++++++-----
 1 file changed, 8 insertions(+), 5 deletions(-)

diff --git a/bin/stampede-worker.js b/bin/stampede-worker.js
index 1a9dfdf..87f7e42 100755
--- a/bin/stampede-worker.js
+++ b/bin/stampede-worker.js
@@ -24,8 +24,8 @@ const conf = require("rc")("stampede", {
   workerName: null,
   stampedeConfigPath: null,
   stampedeScriptPath: null,
-  taskQueue: "stampede-tasks",
-  responseQueue: "stampede-response",
+  taskQueue: "tasks",
+  responseQueue: "response",
   workspaceRoot: null,
   // Test mode. Set both of these to enable test mode
   // where the worker will execute the task that is in the
@@ -45,7 +45,7 @@ const conf = require("rc")("stampede", {
   taskDetailsLogFile: "worker.log",
   logQueuePath: null,
   // Heartbeat
-  heartbeatQueue: "stampede-heartbeat",
+  heartbeatQueue: "heartbeat",
   heartbeatInterval: 15000
 });
 
@@ -91,10 +91,13 @@ if (
 
 if (conf.taskTestFile == null) {
   const workerQueue = new Queue("stampede-" + conf.taskQueue, redisConfig);
-  const responseQueue = new Queue(conf.responseQueue, redisConfig);
+  const responseQueue = new Queue(
+    "stampede-" + conf.responseQueue,
+    redisConfig
+  );
   const heartbeatQueue =
     conf.heartbeatQueue != null
-      ? new Queue(conf.heartbeatQueue, redisConfig)
+      ? new Queue("stampede-" + conf.heartbeatQueue, redisConfig)
       : null;
 
   workerQueue.process(function(task) {