diff --git a/lib/dbqueuemanager.php b/lib/dbqueuemanager.php index 26e13911ee..f843d6d9e6 100644 --- a/lib/dbqueuemanager.php +++ b/lib/dbqueuemanager.php @@ -44,7 +44,7 @@ class DBQueueManager extends QueueManager $qi->created = common_sql_now(); $result = $qi->insert(); - if (!$result) { + if ($result === false) { common_log_db_error($qi, 'INSERT', __FILE__); throw new ServerException('DB error inserting queue item'); } diff --git a/lib/queuemanager.php b/lib/queuemanager.php index 0e37ab0c53..dde78264d0 100644 --- a/lib/queuemanager.php +++ b/lib/queuemanager.php @@ -67,6 +67,9 @@ abstract class QueueManager extends IoManager self::$qm = new UnQueueManager(); } else { switch ($type) { + case 'cron': + self::$qm = new GNUsocialCron(); + break; case 'db': self::$qm = new DBQueueManager(); break; diff --git a/scripts/getvaliddaemons.php b/scripts/getvaliddaemons.php index 78cbba8c07..b4e1e57e43 100755 --- a/scripts/getvaliddaemons.php +++ b/scripts/getvaliddaemons.php @@ -37,7 +37,7 @@ require_once INSTALLDIR.'/scripts/commandline.inc'; $daemons = array(); -$daemons[] = INSTALLDIR.'/scripts/queuedaemon.php'; +#$daemons[] = INSTALLDIR.'/scripts/queuedaemon.php'; if (Event::handle('GetValidDaemons', array(&$daemons))) { foreach ($daemons as $daemon) {