X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;ds=sidebyside;f=scripts%2Fombqueuehandler.php;h=1df816d1403e2b49566313a8b57a048623a9ce1f;hb=85b9e58e535d44f5973fe14f888dc19f25bcaddd;hp=36d5d7b9c1c7115f1791943d3462ef9a8f6a2254;hpb=972e03b158259219d02a4c1edb85fac71d52e0c7;p=quix0rs-gnu-social.git

diff --git a/scripts/ombqueuehandler.php b/scripts/ombqueuehandler.php
index 36d5d7b9c1..1df816d140 100755
--- a/scripts/ombqueuehandler.php
+++ b/scripts/ombqueuehandler.php
@@ -40,12 +40,16 @@ class OmbQueueHandler extends QueueHandler {
 	}
 	
 	function start() {
+		$this->log(LOG_INFO, "INITIALIZE");
 		return true;
 	}
 
 	function handle_notice($notice) {
-		if (!$this->is_remote($notice)) {
-			omb_broadcast_remote_subscribers($notice);
+		if ($this->is_remote($notice)) {
+			$this->log(LOG_DEBUG, 'Ignoring remote notice ' . $notice->id);
+			return true;
+		} else {
+			return omb_broadcast_remote_subscribers($notice);
 		}
 	}
 	
@@ -54,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();