check the state of the queue before diving in to process it

darcs-hash:20080830095709-84dde-a64262c1b32e506cb2c43f8b4fb55ab88effc22f.gz

1 files changed, 8 insertions, 2 deletions

diff --git a/scripts/xmppqueuehandler.php b/scripts/xmppqueuehandler.php
index 040191c28..52db0eb59 100755
--- a/scripts/xmppqueuehandler.php
+++ b/scripts/xmppqueuehandler.php
@@ -53,9 +53,15 @@ class XmppQueueHandler extends QueueHandler {
 	}
 
 	function idle() {
-	        $this->log(LOG_DEBUG, 'Processing the incoming message queue.');
+	    $this->log(LOG_DEBUG, 'Checking the incoming message queue.');
 		# Process the queue for a second
-		$this->conn->processTime(1);
+		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.');
+		}
 	}
 
 	function finish() {