summaryrefslogtreecommitdiff
path: root/scripts/xmppqueuehandler.php
diff options
context:
space:
mode:
authorEvan Prodromou <evan@prodromou.name>2008-08-30 20:32:10 -0400
committerEvan Prodromou <evan@prodromou.name>2008-08-30 20:32:10 -0400
commitd5f83d92521dbf838b1fc1fad2716efc3122c6b7 (patch)
tree5318e5c4ad04f8415b2d6d57cddcd03c85b6560d /scripts/xmppqueuehandler.php
parentea5b12916342910d9df18af69f82a4f3aedb6d4b (diff)
switch around how XMLStream does processing
darcs-hash:20080831003210-84dde-92ccffd5b2e1d50963b18babd93c70fb1d20cdba.gz
Diffstat (limited to 'scripts/xmppqueuehandler.php')
-rwxr-xr-xscripts/xmppqueuehandler.php11
1 files changed, 2 insertions, 9 deletions
diff --git a/scripts/xmppqueuehandler.php b/scripts/xmppqueuehandler.php
index c6f5c3f12..7f1e6c28f 100755
--- a/scripts/xmppqueuehandler.php
+++ b/scripts/xmppqueuehandler.php
@@ -56,16 +56,9 @@ class XmppQueueHandler extends QueueHandler {
return jabber_broadcast_notice($notice);
}
- function idle() {
- $this->log(LOG_DEBUG, 'Checking the incoming message queue.');
+ function idle($timeout=0) {
# Process the queue for a second
- if ($this->conn->readyToProcess()) {
- $this->log(LOG_DEBUG, 'Something in the incoming message queue; processing it.');
- $this->conn->processTime(1);
- $this->log(LOG_DEBUG, 'Done processing incoming message queue.');
- } else {
- $this->log(LOG_DEBUG, 'Nothing in the incoming message queue; skipping it.');
- }
+ $this->conn->processTime($timeout);
}
function finish() {