Pchen. 1 month ago
parent
commit
4e08967984
1 changed files with 2 additions and 1 deletions
  1. 2 1
      plugin/mq/runforgeTaskMq.js

+ 2 - 1
plugin/mq/runforgeTaskMq.js

@@ -1,4 +1,5 @@
-const TASK_QUEUE = 'runforge_task_queue'
+const { mq } = require('./mqPrefix')
+const TASK_QUEUE = mq('runforge_task_queue')
 
 
 /**
 /**
  * 声明乐跑任务主队列(无 RabbitMQ 插件)
  * 声明乐跑任务主队列(无 RabbitMQ 插件)