PEIP_Simple_Messaging_Gateway.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_Simple_Messaging_Gateway 
    implements 
        PEIP_INF_Messaging_Gateway,
        PEIP_INF_Message_Builder {

    protected 
        $requestChannel,
        $replyChannel,
        $messageClass = 'PEIP_Generic_Message',
        $defaultHeaders,
        $messageBuilder; 

    
    public function __construct(PEIP_INF_Channel $requestChannel, PEIP_INF_Channel $replyChannel = NULL, array $defaultHeaders = array()){
        $this->setRequestChannel($requestChannel);
        $this->setReplyChannel($replyChannel);
        $this->defaultHeaders = $defaultHeaders;
        $this->messageBuilder = PEIP_Message_Builder::getInstance($this->messageClass);
    }   
            
    
    public function setRequestChannel(PEIP_INF_Channel $requestChannel){
        $this->requestChannel = $requestChannel;
    }

    
    public function setReplyChannel(PEIP_INF_Channel $replyChannel){
        if(!($replyChannel instanceof PEIP_INF_Pollable_Channel)){
            throw new InvalidArgumentException('reply channel must be instance of PEIP_INF_Pollable_Channel.');
        }       
        $this->replyChannel = $replyChannel;
    }

    
    public function send($content){
        return $this->requestChannel->send($this->buildMessage($content));
    }

    
    public function receive(){
        if(!isset($this->replyChannel)){
            throw new LogicException('No replyChannel set.');
        }       
        $message = $this->replyChannel->receive();
        if($message){
            return $message;
        }
        
        //return $this->replyChannel->receive()->getContent();
    }
    
    
    public function sendAndReceive($content){
        $this->send($content);
        try {
            $res = $this->receive();
        }
        catch(Exception $e){
            return NULL;
        }
        return $res;
    }

    
    
    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)->setHeaders($this->defaultHeaders);
    }
    
    
    
    public function setMessageClass($messageClass){
        $this->messageClass = $messageClass;
    }

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

}

---