one more shot at servicing queues
This commit is contained in:
parent
43e0b308fd
commit
0828fde51c
@ -122,12 +122,7 @@ class StompQueueManager
|
|||||||
if (in_array($stompsock, $read)) {
|
if (in_array($stompsock, $read)) {
|
||||||
$this->_handleNotice($queue, $handler);
|
$this->_handleNotice($queue, $handler);
|
||||||
}
|
}
|
||||||
foreach ($handsocks as $sock) {
|
$handler->idle(QUEUE_HANDLER_HIT_IDLE);
|
||||||
if (in_array($sock, $read)) {
|
|
||||||
$handler->idle(QUEUE_HANDLER_HIT_IDLE);
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user