summaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
authorEvan Prodromou <evan@controlyourself.ca>2009-07-09 12:49:37 -0400
committerEvan Prodromou <evan@controlyourself.ca>2009-07-09 12:49:37 -0400
commit031146f4c757ca00fb9f528abf69ef4b229bdc18 (patch)
tree74bde736e8705575f150f29b90b3a87ffb32c3c8 /lib
parenteccab870444463734b8fcd7ec0f1cf149a0f6a57 (diff)
yet another select() refinement
Diffstat (limited to 'lib')
-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;
+ }
+ }
}
}