123456789101112131415161718192021222324252627282930313233343536 |
- <?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);
- }
- }
- }
|