PEIP_Queue_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_Queue_Channel 
    extends PEIP_ABS_Pollable_Channel {

    protected 
        $capacity,
        $queue; 
        
    
    public function __construct($capacity = -1){
        $this->setCapacity((int)$capacity);
        $this->queue = new SplQueue();  
    }   
        
    
    public function getMessageCount(){
        return count($this->messages);
    }   

    
    public function getCapacity(){
        return $this->capacity;
    }       

    
    public function setCapacity($capacity){
        $this->capacity = $capacity;
    }   

    
    protected function doSend(PEIP_INF_Message $message){
        if($this->capacity < 1 || $this->getMessageCount() <= $this->getCapacity()){
            $this->queue->enqueque($message);
        }else{
            throw new Exception('Not implemented yet.');
        }            
    }       
} 

---