summaryrefslogtreecommitdiff
path: root/lib/stompqueuemanager.php
diff options
context:
space:
mode:
authorEvan Prodromou <evan@controlyourself.ca>2009-07-09 15:25:59 -0400
committerEvan Prodromou <evan@controlyourself.ca>2009-07-09 15:25:59 -0400
commit0828fde51ccb1a5629ab33dd23834070b95c0f37 (patch)
treed58e04e2bd0f1263c777a1e8e746f3b064c6d342 /lib/stompqueuemanager.php
parent43e0b308fdb32ed434d25b54b4a84b88d329d1bf (diff)
one more shot at servicing queues
Diffstat (limited to 'lib/stompqueuemanager.php')
-rw-r--r--lib/stompqueuemanager.php7
1 files changed, 1 insertions, 6 deletions
diff --git a/lib/stompqueuemanager.php b/lib/stompqueuemanager.php
index d13af3fa5..46baeb5c7 100644
--- a/lib/stompqueuemanager.php
+++ b/lib/stompqueuemanager.php
@@ -122,12 +122,7 @@ 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);
- break;
- }
- }
+ $handler->idle(QUEUE_HANDLER_HIT_IDLE);
}
}