1

application/admin/controller/Queue.php

@@ -53,7 +53,7 @@ class Queue extends Controller
             $this->command = ProcessService::instance()->think('xtask:start');
             $this->listen = preg_match('/process.*?\d+.*?running/', $this->message, $attr);
 
-            $listen = ProcessService::instance()->think('xtask:_work');
+            $listen = ProcessService::instance()->query('xtask:_work');
             dump($listen);
 
         } catch (\Exception $exception) {