<?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> // +---------------------------------------------------------------------- \think\Console::addDefaultCommands([ "think\\queue\\command\\Work", "think\\queue\\command\\Restart", "think\\queue\\command\\Listen", "think\\queue\\command\\Subscribe" ]); if (!function_exists('queue')) { /** * 添加到队列 * @param $job * @param string $data * @param int $delay * @param null $queue */ function queue($job, $data = '', $delay = 0, $queue = null) { if ($delay > 0) { \think\Queue::later($delay, $job, $data, $queue); } else { \think\Queue::push($job, $data, $queue); } } }