* @version 0.0.0 * @copyright Copyright (c) 2007, 2008 Roland Haeder, 2009 Hub Developer Team * @license GNU GPL 3.0 or any newer version * @link http://www.ship-simu.org * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program. If not, see . */ class DefaultListenerPool extends BasePool implements PoolableListener { /** * Protected constructor * * @return void */ protected function __construct () { // Call parent constructor parent::__construct(__CLASS__); } /** * Creates an instance of this class * * @param $nodeInstance A NodeHelper instance * @return $listenerInstance An instance a prepared listener class */ public final static function createDefaultListenerPool (NodeHelper $nodeInstance) { // Get new instance $listenerInstance = new DefaultListenerPool(); // Set the application instance $listenerInstance->setNodeInstance($nodeInstance); // Return the prepared instance return $listenerInstance; } /** * Adds a listener instance to this pool * * @param $listenerInstance An instance of a Listenable class * @return void */ public function addListener (Listenable $listenerInstance) { // Add this listener instance to the instance list parent::addInstance($listenerInstance->getProtocol(), 'listener', $listenerInstance); // Debug message $this->debugOutput( 'POOL: Listener ' . $listenerInstance->__toString() . ' listening to ' . $listenerInstance->getListenAddress() . ':' . $listenerInstance->getListenPort() . ' added to listener pool.' ); } /** * Run the shutdown seqeuence by a Visitor Pattern * * @return void */ public function doShutdown () { // Debug message $this->debugOutput('POOL: Shutting down listener pool - START'); // Get a new visitor $visitorInstance = ObjectFactory::createObjectByConfiguredName('listener_pool_visitor_class'); // Start visiting $this->accept($visitorInstance); // Debug message $this->debugOutput('POOL: Shutting down listener pool - FINISHED'); } } // [EOF] ?>