From 9c5c988ef701d7a983252ec7bc2788e314ed1af3 Mon Sep 17 00:00:00 2001
From: Anyon <zoujingli@qq.com>
Date: Mon, 11 May 2020 16:43:58 +0800
Subject: [PATCH] Update Queue.php

---
 app/admin/controller/Queue.php | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/app/admin/controller/Queue.php b/app/admin/controller/Queue.php
index 50997783c..40690f548 100644
--- a/app/admin/controller/Queue.php
+++ b/app/admin/controller/Queue.php
@@ -46,8 +46,8 @@ class Queue extends Controller
     public function index()
     {
         if (AdminService::instance()->isSuper()) try {
-            $this->command = ProcessService::instance()->think('xtask:start');
-            $this->message = $this->app->console->call('xtask:state')->fetch();
+            $this->command = ProcessService::instance()->think('xadmin:queue start');
+            $this->message = $this->app->console->call('xadmin:queue', ['status'])->fetch();
             $this->listen = preg_match('/process.*?\d+.*?running/', $this->message, $attr);
         } catch (\Exception $exception) {
             $this->listen = false;
@@ -105,7 +105,7 @@ class Queue extends Controller
     public function start()
     {
         try {
-            $message = nl2br($this->app->console->call('xtask:start')->fetch());
+            $message = nl2br($this->app->console->call('xadmin:queue', ['start'])->fetch());
             if (preg_match('/process.*?\d+/', $message, $attr)) {
                 $this->success('任务监听主进程启动成功！');
             } else {
@@ -125,7 +125,7 @@ class Queue extends Controller
     public function stop()
     {
         try {
-            $message = nl2br($this->app->console->call('xtask:stop')->fetch());
+            $message = nl2br($this->app->console->call('xadmin:queue', ['stop'])->fetch());
             if (stripos($message, 'succeeded')) {
                 $this->success('停止任务监听主进程成功！');
             } elseif (stripos($message, 'finish')) {