X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=lib%2Fstompqueuemanager.php;h=f059b42f0095f69f5db827bbf3f5698d128f87ba;hb=150cf8c045e8e091a70440d1b833fa19aaf31419;hp=d13af3fa5266702e1446cca926b3c93a27dd3b26;hpb=031146f4c757ca00fb9f528abf69ef4b229bdc18;p=quix0rs-gnu-social.git diff --git a/lib/stompqueuemanager.php b/lib/stompqueuemanager.php index d13af3fa52..f059b42f00 100644 --- a/lib/stompqueuemanager.php +++ b/lib/stompqueuemanager.php @@ -1,6 +1,6 @@ . * * @category QueueManager - * @package Laconica - * @author Evan Prodromou - * @author Sarven Capadisli - * @copyright 2009 Control Yourself, Inc. + * @package StatusNet + * @author Evan Prodromou + * @author Sarven Capadisli + * @copyright 2009 StatusNet, Inc. * @license http://www.fsf.org/licensing/licenses/agpl-3.0.html GNU Affero General Public License version 3.0 - * @link http://laconi.ca/ + * @link http://status.net/ */ require_once 'Stomp.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); } }