<?php
/**
 * 文件MQ
 *
 * - 队列存放于本地文件 中，不支持分布式MQ
 *
 * @author dogstar <chanzonghuang@gmail.com> 20150516
 */

class Task_MQ_File extends Task_MQ_KeyValue {

    public function __construct(PhalApi_Cache_File $fileCache = NULL) {
        if ($fileCache === NULL) {
            $config = DI()->config->get('app.Task.mq.file');
            if (!isset($config['path'])) {
                $config['path'] = API_ROOT . '/Runtime';
            }
            if (!isset($config['prefix'])) {
                $config['prefix'] = 'phalapi_task';
            }

            $fileCache = new PhalApi_Cache_File($config);
        }

        parent::__construct($fileCache);
    }
}