diff options
| -rwxr-xr-x | scripts/ombqueuehandler.php | 7 | ||||
| -rwxr-xr-x | scripts/xmppqueuehandler.php | 2 |
2 files changed, 6 insertions, 3 deletions
diff --git a/scripts/ombqueuehandler.php b/scripts/ombqueuehandler.php index 36d5d7b9c..28c76db9a 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 e6f5368f4..8fe8b1360 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() { |