<?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>
|
// +----------------------------------------------------------------------
|
|
namespace think\queue\command;
|
|
use think\Cache;
|
use think\console\Command;
|
use think\console\Input;
|
use think\console\Output;
|
|
class Restart extends Command
|
{
|
public function configure()
|
{
|
$this->setName('queue:restart')->setDescription('Restart queue worker daemons after their current job');
|
}
|
|
public function execute(Input $input, Output $output)
|
{
|
Cache::set('think:queue:restart', time());
|
$output->writeln("<info>Broadcasting queue restart signal.</info>");
|
}
|
}
|
