fixed #478

hhxsv5 · hhxsv5 · commit 01132ea122b6 · 2024-09-12T22:50:46.000+08:00
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);
             }
         }

Original file line number	Diff line number	Diff line change
`@@ -99,9 +99,9 @@ public function makeProcess(callable $callback, array $config)`
`99`	`99`	`if (empty($config['queue'])) {`
`100`	`100`	`$process->useQueue();`
`101`	`101`	`} else {`
`102`		`- $msgKey = isset($config['msg_key']) ? $config['msg_key'] : 0;`
`103`		`- $mode = isset($config['mode']) ? $config['mode'] : 2;`
`104`		`- $capacity = isset($config['capacity']) ? $config['capacity'] : -1;`
	`102`	`+ $msgKey = isset($config['queue']['msg_key']) ? $config['queue']['msg_key'] : 0;`
	`103`	`+ $mode = isset($config['queue']['mode']) ? $config['queue']['mode'] : 2;`
	`104`	`+ $capacity = isset($config['queue']['capacity']) ? $config['queue']['capacity'] : -1;`
`105`	`105`	`$process->useQueue($msgKey, $mode, $capacity);`
`106`	`106`	`}`
`107`	`107`	`}`