repo_mongoAdapter/lib/Mooses/Mongodb/Queue/Abstractadapter.php

<?php

/**
 * Created by PhpStorm.
 * User: paolo
 * Date: 14/12/15
 * Time: 16:13
 * @Db: vodafonectc_ordini
 * @Collection: orderqueue
 */
class Mooses_Mongodb_Queue_Abstractadapter extends Mooses_AbstractMongo
{

    protected $_fields = array("message_id" => NULL, "queue_id" => NULL, "handle" => 0, "body" => "", "md5" => NULL, "timeout" => 0, "created" => 0 , "retrials" => 0, "retrial_messages" => NULL);
    public function __construct($_data)
    {
        if(count($_data) == 0){
            $_data = $this->_data;
        }
        parent::__construct($_data);
    }

    public function ___setData($_key, $_value = NULL)
    {
        if(in_array($_key, $this->_fields)) {
            return parent::___setData($_key, $_value, true);
        } else {
            return $this;
        }
    }
}