diff --git a/Kafka/Kafka.php b/Kafka/Kafka.php index 3b8662df..fdd77488 100644 --- a/Kafka/Kafka.php +++ b/Kafka/Kafka.php @@ -39,8 +39,11 @@ class Kafka extends \Snowflake\Process\Process { $this->channelListener(); - Process::signal(SIGUSR1, function () use ($process) { - var_dump($process); + go(function () use ($process) { + $sign = Coroutine::waitSignal(SIGUSR1 | SIGTERM | SIGKILL, -1); + + + var_dump($sign); }); $waite = new WaitGroup();