From: Brion Vibber <brion@pobox.com>
Date: Thu, 28 Jan 2010 02:39:17 +0000 (-0800)
Subject: Adds an emergency switch so we can run inbox distribution at save time (bypassing... 
X-Git-Url: https://git.mxchange.org/?a=commitdiff_plain;h=3abfb454a381806a0f237e1463d2ba9a8612c22a;p=quix0rs-gnu-social.git

Adds an emergency switch so we can run inbox distribution at save time (bypassing 'distrib' queue)
Set $config['queue']['inboxes'] = false to do so
---

diff --git a/classes/Notice.php b/classes/Notice.php
index 0966697e21..6b364fb5ce 100644
--- a/classes/Notice.php
+++ b/classes/Notice.php
@@ -326,9 +326,13 @@ class Notice extends Memcached_DataObject
         # XXX: someone clever could prepend instead of clearing the cache
         $notice->blowOnInsert();
 
-        $qm = QueueManager::get();
-
-        $qm->enqueue($notice, 'distrib');
+        if (common_config('queue', 'inboxes')) {
+            $qm = QueueManager::get();
+            $qm->enqueue($notice, 'distrib');
+        } else {
+            $handler = new DistribQueueHandler();
+            $handler->handle($notice);
+        }
 
         return $notice;
     }
diff --git a/lib/default.php b/lib/default.php
index 10ea348640..c729193b52 100644
--- a/lib/default.php
+++ b/lib/default.php
@@ -87,6 +87,7 @@ $default =
               'monitor' => null, // URL to monitor ping endpoint (work in progress)
               'softlimit' => '90%', // total size or % of memory_limit at which to restart queue threads gracefully
               'debug_memory' => false, // true to spit memory usage to log
+              'inboxes' => true, // true to do inbox distribution & output queueing from in background via 'distrib' queue
               ),
         'license' =>
         array('type' => 'cc', # can be 'cc', 'allrightsreserved', 'private'