X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=scripts%2Fombqueuehandler.php;h=1df816d1403e2b49566313a8b57a048623a9ce1f;hb=85b9e58e535d44f5973fe14f888dc19f25bcaddd;hp=28c76db9a6fa4ab11e760f23d63c2ac9e91ae176;hpb=cde3bc585fd7763a4840fc865f1cc4164c22293e;p=quix0rs-gnu-social.git

diff --git a/scripts/ombqueuehandler.php b/scripts/ombqueuehandler.php
index 28c76db9a6..1df816d140 100755
--- a/scripts/ombqueuehandler.php
+++ b/scripts/ombqueuehandler.php
@@ -40,12 +40,13 @@ class OmbQueueHandler extends QueueHandler {
 	}
 	
 	function start() {
+		$this->log(LOG_INFO, "INITIALIZE");
 		return true;
 	}
 
 	function handle_notice($notice) {
 		if ($this->is_remote($notice)) {
-			# It's fine, we're done with it.
+			$this->log(LOG_DEBUG, 'Ignoring remote notice ' . $notice->id);
 			return true;
 		} else {
 			return omb_broadcast_remote_subscribers($notice);
@@ -57,18 +58,17 @@ class OmbQueueHandler extends QueueHandler {
 
 	function is_remote($notice) {
 		$user = User::staticGet($notice->profile_id);
-		return !$user;
+		return is_null($user);
 	}
 }
 
+ini_set("max_execution_time", "0");
+ini_set("max_input_time", "0");
+set_time_limit(0);
 mb_internal_encoding('UTF-8');
 
 $id = ($argc > 1) ? $argv[1] : NULL;
 
 $handler = new OmbQueueHandler($id);
 
-if ($handler->start()) {
-	$handler->handle_queue();
-}
-
-$handler->finish();
+$handler->runOnce();