恢复队列名称

app/jobs/agent/AutoAgentJob.php

@@ -21,7 +21,7 @@ class AutoAgentJob extends BaseJobs
      */
     protected static function queueName()
     {
-        return 'ruiRoad_PRO_TASK';
+        return 'CRMEB_PRO_TASK';
     }
 
     /**

app/jobs/live/AutoUpdateLiveJob.php

@@ -22,7 +22,7 @@ class AutoUpdateLiveJob extends BaseJobs
      */
     protected static function queueName()
     {
-        return 'ruiRoad_PRO_TASK';
+        return 'CRMEB_PRO_TASK';
     }
 
     public function doJob()

app/jobs/order/AutoOrderUnpaidCancelJob.php

@@ -22,7 +22,7 @@ class AutoOrderUnpaidCancelJob extends BaseJobs
      */
     protected static function queueName()
     {
-        return 'ruiRoad_PRO_TASK';
+        return 'CRMEB_PRO_TASK';
     }
 
     /**

app/jobs/order/AutoTakeOrderJob.php

@@ -23,7 +23,7 @@ class AutoTakeOrderJob extends BaseJobs
      */
     protected static function queueName()
     {
-        return 'ruiRoad_PRO_TASK';
+        return 'CRMEB_PRO_TASK';
     }
 
     /**

app/jobs/order/OrderTakeJob.php

@@ -24,7 +24,7 @@ class OrderTakeJob extends BaseJobs
      */
     protected static function queueName()
     {
-        return 'ruiRoad_PRO_TASK';
+        return 'CRMEB_PRO_TASK';
     }
 
     public function doJob($order)

app/jobs/pink/AuthPinkFail.php

@@ -24,7 +24,7 @@ class AuthPinkFail extends BaseJobs
      */
     protected static function queueName()
     {
-        return 'ruiRoad_PRO_TASK';
+        return 'CRMEB_PRO_TASK';
     }
 
     /**

app/jobs/system/AutoClearPosterJob.php

@@ -21,7 +21,7 @@ class AutoClearPosterJob extends BaseJobs
      */
     protected static function queueName()
     {
-        return 'ruiRoad_PRO_TASK';
+        return 'CRMEB_PRO_TASK';
     }
 
     /**

app/jobs/system/AutoSmsCodeJob.php

@@ -21,7 +21,7 @@ class AutoSmsCodeJob extends BaseJobs
      */
     protected static function queueName()
     {
-        return 'ruiRoad_PRO_TASK';
+        return 'CRMEB_PRO_TASK';
     }
 
     /**

app/jobs/user/AutoClearIntegralJob.php

@@ -21,7 +21,7 @@ class AutoClearIntegralJob extends BaseJobs
      */
     protected static function queueName()
     {
-        return 'ruiRoad_PRO_TASK';
+        return 'CRMEB_PRO_TASK';
     }
 
     public function doJob()

config/swoole.php

@@ -53,10 +53,10 @@ return strtoupper(substr(php_uname('s'), 0, 3)) === 'WIN' ? [] : [
     'queue' => [
         'enable' => true,
         'workers' => [
-            'ruiRoad_PRO' => [],
-            'ruiRoad_PRO_BATCH' => [],
-            'ruiRoad_PRO_TASK' => [],
-            'ruiRoad_PRO_ERP' => [],
+            'CRMEB_PRO' => [],
+            'CRMEB_PRO_BATCH' => [],
+            'CRMEB_PRO_TASK' => [],
+            'CRMEB_PRO_ERP' => [],
         ],
     ],
     //热更新