summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--lib/stompqueuemanager.php9
1 files changed, 6 insertions, 3 deletions
diff --git a/lib/stompqueuemanager.php b/lib/stompqueuemanager.php
index ac55f9733..d13af3fa5 100644
--- a/lib/stompqueuemanager.php
+++ b/lib/stompqueuemanager.php
@@ -122,9 +122,12 @@ class StompQueueManager
if (in_array($stompsock, $read)) {
$this->_handleNotice($queue, $handler);
}
- $handler->idle(QUEUE_HANDLER_HIT_IDLE);
- } else { // timeout
- $handler->idle(QUEUE_HANDLER_MISS_IDLE);
+ foreach ($handsocks as $sock) {
+ if (in_array($sock, $read)) {
+ $handler->idle(QUEUE_HANDLER_HIT_IDLE);
+ break;
+ }
+ }
}
}