 <?php
/**
 * ShopEx licence
 *
 * @copyright  Copyright (c) 2005-2010 ShopEx Technologies Inc. (http://www.shopex.cn)
 * @license  http://ecos.shopex.cn/ ShopEx License
 */
class base_queue
{
    private $queue;
    public function __construct()
    {
        if(!defined('MESSAGE_QUEUE') || !constant('MESSAGE_QUEUE')) {
            define('MESSAGE_QUEUE', 'base_queue_mysql');
        }
        return $this->set_queue(kernel::single(MESSAGE_QUEUE));
    }

    public function publish($message)   
    {
       return $this->queue->publish($message); 
    }

    public function consume()
    {
        return $this->queue->consume();
    }

    private function set_queue(base_interface_queue $queue)
    {
        $this->queue = $queue;
        return $this->queue;
    }

}

