usr bin env php php define BASEPATH define APPPATH require_once librar

#!/usr/bin/env php
<?php

define('BASEPATH', '../../');
define('APPPATH', '../');

require_once("../libraries/DoctrineORM.php");
require_once("SystemDaemon.php");

new DoctrineORM;

class NaiveConsumer extends SystemDaemon
{

  public function process()
  {
    $timestamp = date('Y-m-d H:i:s', time());
    $events = Queue::receiveEvents($timestamp);
    $this->log->debug("Receive events (%d)", $events->count());
    foreach ($events as $event)
    {
      $this->log->debug("Got event %d -- %s (should fire at %s)",
                        $event['EventID'], $event['EventName'],
                        $event['ShouldFireAt']);
      // do something with event
      // and mark it's done
      Queue::markEventDone($event['EventID']);
    }
  }
}


$consumer = new NaiveConsumer($argc, $argv);

?>