better queue manager detection, new method fail()

This commit is contained in:
Evan Prodromou 2009-07-01 12:09:18 -04:00
parent e0bf8ad95b
commit 887d35cfc8

View File

@ -39,13 +39,12 @@ class QueueManager
if (Event::handle('StartNewQueueManager', array(&self::$qm))) { if (Event::handle('StartNewQueueManager', array(&self::$qm))) {
$enabled = common_config('queue', 'enabled'); $enabled = common_config('queue', 'enabled');
$type = common_config('queue', 'sub'); $type = common_config('queue', 'subsystem');
if (!$enabled) { if (!$enabled) {
// does everything immediately // does everything immediately
return new UnQueueManager(); self::$qm = new UnQueueManager();
} } else {
switch ($type) { switch ($type) {
case 'db': case 'db':
self::$qm = new DBQueueManager(); self::$qm = new DBQueueManager();
@ -57,6 +56,7 @@ class QueueManager
throw new ServerException("No queue manager class for type '$type'"); throw new ServerException("No queue manager class for type '$type'");
} }
} }
}
return self::$qm; return self::$qm;
} }
@ -81,4 +81,9 @@ class QueueManager
{ {
throw ServerException("Unimplemented function 'done' called"); throw ServerException("Unimplemented function 'done' called");
} }
function fail($object, $queue)
{
throw ServerException("Unimplemented function 'fail' called");
}
} }