修复消息队列消费进程问题

1a74ac01 · weixin_47267244 · 3ec72a08 · 1a74ac01
隐藏空白更改
内联并排

Showing with 2 addition and 0 deletion

src/Components/queue/src/Process/QueueConsumerProcess.php src/Components/queue/src/Process/QueueConsumerProcess.php +2 -0

未找到文件。
--- a/src/Components/queue/src/Process/QueueConsumerProcess.php
+++ b/src/Components/queue/src/Process/QueueConsumerProcess.php
@@ -8,6 +8,7 @@ use Imi\Process\Annotation\Process;
 use Imi\Process\BaseProcess;
 use Imi\Util\Imi;
 use Swoole\Coroutine;
+use Swoole\Event;

 /**
 * 队列消费进程.
@@ -81,5 +82,6 @@ class QueueConsumerProcess extends BaseProcess
            });
            $processPool->start();
        }
+        Event::wait();
    }
 }