<?php// +----------------------------------------------------------------------// | ThinkPHP [ WE CAN DO IT JUST THINK IT ]// +----------------------------------------------------------------------// | Copyright (c) 2006-2015 http://thinkphp.cn All rights reserved.// +----------------------------------------------------------------------// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )// +----------------------------------------------------------------------// | Author: yunwuxin <448901948@qq.com>// +----------------------------------------------------------------------namespacethink\queue\command;usethink\Cache;usethink\console\Command;usethink\console\Input;usethink\console\Output;classRestartextendsCommand{publicfunctionconfigure(){$this->setName('queue:restart')->setDescription('Restart queue worker daemons after their current job');}publicfunctionexecute(Input$input,Output$output){Cache::set('think:queue:restart',time());$output->writeln("<info>Broadcasting queue restart signal.</info>");}}