diff --git a/scripts/ombqueuehandler.php b/scripts/ombqueuehandler.php index 36d5d7b9c1..28c76db9a6 100755 --- a/scripts/ombqueuehandler.php +++ b/scripts/ombqueuehandler.php @@ -44,8 +44,11 @@ class OmbQueueHandler extends QueueHandler { } function handle_notice($notice) { - if (!$this->is_remote($notice)) { - omb_broadcast_remote_subscribers($notice); + if ($this->is_remote($notice)) { + # It's fine, we're done with it. + return true; + } else { + return omb_broadcast_remote_subscribers($notice); } } diff --git a/scripts/xmppqueuehandler.php b/scripts/xmppqueuehandler.php index e6f5368f48..8fe8b1360a 100755 --- a/scripts/xmppqueuehandler.php +++ b/scripts/xmppqueuehandler.php @@ -46,7 +46,7 @@ class XmppQueueHandler extends QueueHandler { } function handle_notice($notice) { - jabber_broadcast_notice($notice); + return jabber_broadcast_notice($notice); } function finish() {