fixed #478

hhxsv5 · Sep 12, 2024 · 01132ea · 01132ea
1 parent 57a5931
commit 01132ea
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/Swoole/Process/CustomProcessTrait.php b/src/Swoole/Process/CustomProcessTrait.php
@@ -99,9 +99,9 @@ public function makeProcess(callable $callback, array $config)
             if (empty($config['queue'])) {
                 $process->useQueue();
             } else {
-                $msgKey = isset($config['msg_key']) ? $config['msg_key'] : 0;
-                $mode = isset($config['mode']) ? $config['mode'] : 2;
-                $capacity = isset($config['capacity']) ? $config['capacity'] : -1;
+                $msgKey = isset($config['queue']['msg_key']) ? $config['queue']['msg_key'] : 0;
+                $mode = isset($config['queue']['mode']) ? $config['queue']['mode'] : 2;
+                $capacity = isset($config['queue']['capacity']) ? $config['queue']['capacity'] : -1;
                 $process->useQueue($msgKey, $mode, $capacity);
             }
         }