修复

imiphp · Apr 29, 2023 · 7db936f · 7db936f
1 parent 2fd0dc4
commit 7db936f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/Components/queue/src/Process/SwooleQueueConsumerProcess.php b/src/Components/queue/src/Process/SwooleQueueConsumerProcess.php
@@ -60,7 +60,7 @@ public function run(\Swoole\Process $process): void
                 $processPool = new \Imi\Swoole\Process\Pool($options['process']);
                 $configs = $options['configs'];
                 $processPool->on('WorkerStart', function (\Imi\Swoole\Process\Pool\WorkerEventParam $e) use ($group, $configs) {
-                    Coroutine::create(function (\Imi\Swoole\Process\Pool\WorkerEventParam $e) use ($group, $configs) {
+                    Coroutine::create(function () use ($group, $configs, $e) {
                         $processName = 'QueueConsumer-' . $group;
                         // 进程开始事件
                         ImiEvent::trigger('IMI.PROCESS.BEGIN', [