PEIP_Event_Pipe.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.
 */

class PEIP_Event_Pipe 
    extends PEIP_ABS_Event_Pipe 
    implements PEIP_INF_Listener {

    protected 
        $eventName; 
    
    
    public function setInputChannel(PEIP_INF_Channel $inputChannel){        
        $this->connectChannel($inputChannel);            
    }     

    
    protected function doReply(PEIP_INF_Message $message){
        $headerMessage = $message->getHeader('MESSAGE');
        if($headerMessage instanceof PEIP_INF_Message){
            return $this->replyMessage($headerMessage);
        }
    }

    
    public function listen(PEIP_INF_Connectable $connectable){
        return $this->doListen($this->eventName, $connectable);     
    }
    
    
    public function unlisten(PEIP_INF_Connectable $connectable){
        return $this->doUnlisten($this->eventName, $connectable);       
    }
    
    
    public function getConnected(){
        return $this->doGetConnected();
    }
    
        
    
    public function disconnectChannel(PEIP_INF_Channel $channel){
        $this->disconnectInputChannel();        
        $this->inputChannel = $channel;         
        $this->connectInputChannel();       
    }
    
    protected function connectInputChannel(){
        if($this->inputChannel && $this->eventName){
            $this->inputChannel->connect($this->eventName, $this);
        }   
    }
    
    
    protected function disconnectInputChannel(){
        if($this->inputChannel && $this->eventName){
            $this->inputChannel->disconnect($this->eventName, $this);
        }       
    }
    
    
    public function setEventName($eventName){
        $this->disconnectInputChannel();
        $this->eventName = $eventName;
        $this->connectInputChannel();
    }
        
}

---