PEIP_ABS_Reply_Producing_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_Reply_Producing_Message_Handler
    extends PEIP_ABS_Message_Handler
    implements PEIP_INF_Message_Builder {
    
    protected 
        $outputChannel,
        $messageClass = 'PEIP_Generic_Message',
        $replyChannelHeaders = array('REPLY_CHANNEL');

    
    public function setOutputChannel(PEIP_INF_Channel $outputChannel){
        $this->doSetOutputChannel($outputChannel);
        return $this;
    }   

    
    protected function doSetOutputChannel(PEIP_INF_Channel $outputChannel){
        $this->outputChannel = $outputChannel;
    }
    
    
    public function getOutputChannel(){
        return $this->outputChannel;
    }

        protected function doGetOutputChannel(PEIP_INF_Message $message){
                $replyChannel = $this->resolveReplyChannel($message);
                return $replyChannel ? $replyChannel : $this->getOutputChannel();               
        }

        protected function resolveReplyChannel(PEIP_INF_Message $message){
                foreach($this->replyChannelHeaders as $header){
                        if($message->hasHeader($header)){
                                return $message->getHeader($header);
                        }
                }
                return NULL;
        }
                
    protected function replyMessage($content){
        $message = $this->ensureMessage($content);      
        $this->doGetOutputChannel($message)->send($message);      
    }

    
    protected function ensureMessage($message){
        return ($message instanceof PEIP_INF_Message) ? $message : $this->buildMessage($message);   
    }
    
    
    protected function buildMessage($content){
        return $this->getMessageBuilder()->setContent($content)->build();   
    }   
    
    
    protected function getMessageBuilder(){
        return isset($this->messageBuilder) && ($this->messageBuilder->getMessageClass() == $this->getMessageClass())
            ? $this->messageBuilder
            : $this->messageBuilder = PEIP_Message_Builder::getInstance($this->messageClass);
    }
      
    public function setMessageClass($messageClass){
        $this->messageClass = $messageClass;
        return $this;
    }

    
    public function getMessageClass(){
        return $this->messageClass;
    }       

    public function addReplyChannelHeader($headerName){
        $this->replyChannelHeaders[] = $headerName;
    }

    
    public function setReplyChannelHeaders(array $headerNames){
        $this->replyChannelHeaders = $headerNames;
        return $this;
    } 

    public function getReplyChannelHeaders(){
        return $this->replyChannelHeaders;
    }
    
    
    
    protected function doHandle(PEIP_INF_Message $message){
        $this->doReply($message);
    }
    
    
    abstract protected function doReply(PEIP_INF_Message $message);
    
    
}

---