From 1a0e17fea6347a95b8e28f12d129279836cf6156 Mon Sep 17 00:00:00 2001
From: Mikael Nordfeldth <mmn@hethane.se>
Date: Wed, 13 Nov 2013 18:15:21 +0100
Subject: [PATCH] Minor queue fixes, probably not very important. Preparing for
cron
---
lib/dbqueuemanager.php | 2 +-
lib/queuemanager.php | 3 +++
scripts/getvaliddaemons.php | 2 +-
3 files changed, 5 insertions(+), 2 deletions(-)
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) {
--
2.39.5