PEIP_ABS_Message_Handler.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_Message_Handler 
    implements PEIP_INF_Handler {
    
    protected 
        $inputChannel;
        
        
    
    public function handle($message){
        return $this->doHandle($message);
    }

    
    public function setInputChannel(PEIP_INF_Channel $inputChannel){
        $this->doSetInputChannel($inputChannel);
        return $this;
    }

    
    protected function doSetInputChannel(PEIP_INF_Channel $inputChannel){
        $this->inputChannel = $inputChannel;    
        $messageHandler = $this;
        if($inputChannel instanceof PEIP_INF_Subscribable_Channel){
            $getMessage = function ($object){
                return $object;
            };  
            $linkChannel = function($handler) use ($messageHandler){
                $messageHandler->getInputChannel()->subscribe($handler);    
            };              
        }else{          
            $getMessage = function ($object){
                return $object->getContent()->receive();
            };  
            $linkChannel = function($handler) use ($messageHandler){
                $messageHandler->getInputChannel()->connect('postSend', $handler);  
            };  
        }   
        $handling = function($object) use ($messageHandler, $getMessage){
            $message = $getMessage($object);
            if(!is_object($message)){ 
                throw new Exception('Could not get Message from Channel');
            }               
            $messageHandler->handle($message);          
        };          
        $handler = new PEIP_Callable_Message_Handler($handling);
        $linkChannel($handler); 
    }
    
    
    
    public function getInputChannel(){
        return $this->inputChannel;
    }   
    
    
    abstract protected function doHandle(PEIP_INF_Message $message);
    
}

---