src/Queue/AggregateQueue.php
function setQueues(array $channels_queue)
    {
        foreach ($channels_queue as $channel => $queue ) {
            if (! is_array($queue) )
                $queue = [$queue];

            $q = array_shift($queue);
            if ( null === $w = array_shift($queue) )
                $w = 1;

            $this->addQueue($channel, $q, $w);
        }

        return $this;
    }
function setQueues(array $channels_queue)
    {
        foreach ($channels_queue as $channel => $queue ) {
            if (! is_array($queue) )
                $queue = [$queue];

            $q = array_shift($queue);
            if ( null === $w = array_shift($queue) )
                $w = 1;

            $this->addQueue($channel, $q, $w);
        }

        return $this;
    }
Set Queues

[
'channel_name' => iQueueDriver,
// or
'channel_name' => [iQueueDriver, $weight]
]

@param iQueueDriver[] $channels_queue

@return $this
@throws \Exception