Mongo job queue

gistfile1.aw

  public function getNextJob()
  {
    $result = $this->_getWriteAdapter()->command(array(
        'findAndModify' => $this->_collectionName,
        'query'  => array(
          'status'     => Cm_Mongo_Model_Job::STATUS_READY,
          'execute_at' => array('$lte' => new MongoDate),
        ),
        'sort'   => array(
          'priority'   => 1,
          'execute_at' => 1,
        ),
        'update' => array(
          '$set' => array(
            'status'     => Cm_Mongo_Model_Job::STATUS_RUNNING,
            'pid'        => getmypid(),
          ),
        ),
        'fields' => $this->getDefaultLoadFields(new Varien_Object),
        'new'    => true,
    ));
    if( empty($result['ok'])) {
      return FALSE;
    }

    $data = $result['value'];
    $job = Mage::getModel('mongo/job');
    $this->hydrate($job, $data, TRUE);
    return $job;
  }