PEIP_ABS_Router.php

Go to the documentation of this file.

<?php

/*
 * This file is part of the PEIP package.
 * (c) 2010 Timo Michna <timomichna/yahoo.de>
 * 
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

abstract class PEIP_ABS_Router 
    extends PEIP_Pipe {

    protected $channelResolver;

    
    public function __construct(PEIP_INF_Channel_Resolver $channelResolver, PEIP_INF_Channel $inputChannel){
        $this->channelResolver = $channelResolver;
        $this->setInputChannel($inputChannel);  
    }               
            
    
    public function setChannelResolver(PEIP_INF_Channel_Resolver $channelResolver){
        $this->channelResolver = $channelResolver;
    }
    
    
    protected function doReply(PEIP_INF_Message $message){  
        $ch = $this->selectChannels($message);
        $channels = is_array($ch) ? $ch : array($ch);
        foreach($channels as $channel){
            $this->setOutputChannel($this->resolveChannel($channel));
            $this->replyMessage($message); 
        }
    }   

    
    protected function resolveChannel($channel){
        if(!($channel instanceof PEIP_INF_Channel)){
            $channel = $this->channelResolver->resolveChannelName($channel);
            if(!$channel){
                throw new RuntimeException('Could not resolve Channel : '.$channel);
            }
        }
        return $channel;
    }
    
    
    abstract protected function selectChannels(PEIP_INF_Message $message);
    

}

---