1

application/admin/controller/Queue.php

@@ -52,6 +52,10 @@ class Queue extends Controller
             $this->message = Console::call('xtask:state')->fetch();
             $this->command = ProcessService::instance()->think('xtask:start');
             $this->listen = preg_match('/process.*?\d+.*?running/', $this->message, $attr);
+
+            $listen = ProcessService::instance()->think('xtask:_work');
+            dump($listen);
+
         } catch (\Exception $exception) {
             $this->listen = false;
             $this->message = $exception->getMessage();