#!/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);
?>