src/Queue/AggregateQueue.php
function addQueue($channel, $queue, $weight = 1)
    {
        $orig    = $channel;
        $channel = $this->_normalizeQueueName($channel);


        if (! $queue instanceof iQueueDriver)
            throw new \Exception(sprintf(
                'Queue must be instance of iQueueDriver; given: (%s).'
                , \Poirot\Std\flatten($queue)
            ));

        if ( isset($this->channels_queue[$channel]) )
            throw new \RuntimeException(sprintf(
                'Channel (%s) is currently filled with (%s) and is not empty.'
                , $orig , get_class( $this->channels_queue[$channel] )
            ));


        $this->channels_queue[$channel]  = $queue;
        $this->channels_weight[$channel] = $weight;
        return $this;
    }
function addQueue($channel, $queue, $weight = 1)
    {
        $orig    = $channel;
        $channel = $this->_normalizeQueueName($channel);


        if (! $queue instanceof iQueueDriver)
            throw new \Exception(sprintf(
                'Queue must be instance of iQueueDriver; given: (%s).'
                , \Poirot\Std\flatten($queue)
            ));

        if ( isset($this->channels_queue[$channel]) )
            throw new \RuntimeException(sprintf(
                'Channel (%s) is currently filled with (%s) and is not empty.'
                , $orig , get_class( $this->channels_queue[$channel] )
            ));


        $this->channels_queue[$channel]  = $queue;
        $this->channels_weight[$channel] = $weight;
        return $this;
    }
function addQueue ( $ channel , $ queue , $ weight = 1 ) { $ orig = $ channel ; $ channel = $ this -> _normalizeQueueName ( $ channel ) ; if ( ! $ queue instanceof iQueueDriver ) throw new \ Exception ( sprintf ( 'Queue must be instance of iQueueDriver; given: (%s).' , \ Poirot \ Std \ flatten ( $ queue ) ) ) ; if ( isset ( $ this -> channels_queue [ $ channel ] ) ) throw new \ RuntimeException ( sprintf ( 'Channel (%s) is currently filled with (%s) and is not empty.' , $ orig , get_class ( $ this -> channels_queue [ $ channel ] ) ) ) ; $ this -> channels_queue [ $ channel ] = $ queue ; $ this -> channels_weight [ $ channel ] = $ weight ; return $ this ; }
Add Queue For Specified Channel

@param string       $channel
@param iQueueDriver $queue
@param int          $weight

@return $this
@throws \Exception
Add Queue For Specified Channel