yet another select() refinement
This commit is contained in:
parent
eccab87044
commit
031146f4c7
@ -122,9 +122,12 @@ class StompQueueManager
|
||||
if (in_array($stompsock, $read)) {
|
||||
$this->_handleNotice($queue, $handler);
|
||||
}
|
||||
foreach ($handsocks as $sock) {
|
||||
if (in_array($sock, $read)) {
|
||||
$handler->idle(QUEUE_HANDLER_HIT_IDLE);
|
||||
} else { // timeout
|
||||
$handler->idle(QUEUE_HANDLER_MISS_IDLE);
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user