diff options
author | Evan Prodromou <evan@controlyourself.ca> | 2009-07-09 15:25:59 -0400 |
---|---|---|
committer | Evan Prodromou <evan@controlyourself.ca> | 2009-07-09 15:25:59 -0400 |
commit | 0828fde51ccb1a5629ab33dd23834070b95c0f37 (patch) | |
tree | d58e04e2bd0f1263c777a1e8e746f3b064c6d342 | |
parent | 43e0b308fdb32ed434d25b54b4a84b88d329d1bf (diff) |
one more shot at servicing queues
-rw-r--r-- | lib/stompqueuemanager.php | 7 |
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); } } |