PEIP_Pollable_Channel.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_Pollable_Channel  
    extends PEIP_ABS_Interceptable_Message_Channel 
    implements PEIP_INF_Pollable_Channel {

    protected 
        $messages = array();
        
    
    protected function doSend(PEIP_INF_Message $message){
        $this->messages[] = $message;        
    }
    
    
    public function receive($timeout = -1){
        $this->getInterceptorDispatcher()->notify('preReceive', array($this));
        $this->doFireEvent('preReceive');
        $message = NULL;
        if($timeout == 0){
            $message = $this->getMessage(); 
        }elseif($timeout < 0){
            while(!$message = $this->getMessage()){
                                
            }
        }else{
            $time = time() + $timeout;
            while(($time > time()) && !$message = $this->getMessage()){
                
            }       
        }
        $this->getInterceptorDispatcher()->notify('postReceive', array($this));
        $this->doFireEvent('postReceive', array('MESSAGE'=>$message));
        return $message;
    }

    
    protected function getMessage(){
        return array_shift($this->messages);
    }
    
    
    public function clear(){
        $this->messages = array();
    }
    
    
    public function purge(PEIP_INF_Message_Selector $selector){
        foreach($this->messages as $key=>$message){
            if(!$selector->acceptMessage($message)){
                unset($this->messages[$key]);   
            }
        }
        return $this->messages;
    }
        
    
}

---