quick fix

CrowdDotDev · Dec 12, 2023 · ef8d10c · ef8d10c
1 parent ddb1143
commit ef8d10c
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 4 deletions.
diff --git a/backend/.env.dist.local b/backend/.env.dist.local
@@ -15,7 +15,8 @@ CROWD_API_JWT_EXPIRES_IN='100 years'
 CROWD_SQS_HOST=localhost
 CROWD_SQS_PORT=9324
 CROWD_SQS_ENDPOINT=http://localhost:9324
-CROWD_SQS_NODEJS_WORKER_QUEUE=http://localhost:9324/000000000000/nodejs-worker-normal.fifo
+CROWD_SQS_NODEJS_WORKER_QUEUE=http://localhost:9324/000000000000/nodejs-worker.fifo
+CROWD_SQS_NODEJS_WORKER_PRIORITY_QUEUE=http://localhost:9324/000000000000/nodejs-worker-normal.fifo
 CROWD_SQS_PYTHON_WORKER_QUEUE=http://localhost:9324/000000000000/python-worker.fifo
 CROWD_SQS_AWS_ACCOUNT_ID=000000000000
 CROWD_SQS_AWS_ACCESS_KEY_ID=x

diff --git a/backend/config/custom-environment-variables.json b/backend/config/custom-environment-variables.json
@@ -17,6 +17,7 @@
     "host": "CROWD_SQS_HOST",
     "port": "CROWD_SQS_PORT",
     "nodejsWorkerQueue": "CROWD_SQS_NODEJS_WORKER_QUEUE",
+    "nodejsWorkerPriorityQueue": "CROWD_SQS_NODEJS_WORKER_PRIORITY_QUEUE",
     "integrationRunWorkerQueue": "CROWD_SQS_INTEGRATION_RUN_WORKER_QUEUE",
     "pythonWorkerQueue": "CROWD_SQS_PYTHON_WORKER_QUEUE",
     "aws": {

diff --git a/backend/src/bin/nodejs-worker.ts b/backend/src/bin/nodejs-worker.ts
@@ -65,9 +65,9 @@ const removeWorkerJob = (): void => {
   processingMessages--
 }
 
-async function handleMessages() {
+async function handleMessages(queue: string) {
   const handlerLogger = getChildLogger('messages', serviceLogger, {
-    queue: SQS_CONFIG.nodejsWorkerQueue,
+    queue,
   })
   handlerLogger.info('Listening for messages!')
 
@@ -181,7 +181,10 @@ setImmediate(async () => {
   await initRedisSeq()
 
   await getNodejsWorkerEmitter()
-  await handleMessages()
+  await Promise.all([
+    handleMessages(SQS_CONFIG.nodejsWorkerQueue),
+    handleMessages(SQS_CONFIG.nodejsWorkerPriorityQueue),
+  ])
 })
 
 const liveFilePath = path.join(__dirname, 'tmp/nodejs-worker-live.tmp')

diff --git a/backend/src/conf/configTypes.ts b/backend/src/conf/configTypes.ts
@@ -23,6 +23,7 @@ export interface SQSConfiguration {
   host?: string
   port?: number
   nodejsWorkerQueue: string
+  nodejsWorkerPriorityQueue: string
   integrationRunWorkerQueue: string
   pythonWorkerQueue: string
   aws: AwsCredentials