src/Queue/AggregateQueue.php
function size($queue = null)
    {
        if ($queue === null) {

            $count = 0;

            /** @var iQueueDriver $queue */
            foreach ($this->channels_queue as $channel => $queue )
                $count += $queue->size($channel);

        } else {
            if (false === $qd = $this->_getQueueOfChannel($queue) )
                throw new \RuntimeException(sprintf(
                    'Channel (%s) is not present when trying to get size.'
                    , $queue
                ));

            $count = $qd->size($queue);
        }

        return $count;
    }
function size($queue = null)
    {
        if ($queue === null) {

            $count = 0;

            /** @var iQueueDriver $queue */
            foreach ($this->channels_queue as $channel => $queue )
                $count += $queue->size($channel);

        } else {
            if (false === $qd = $this->_getQueueOfChannel($queue) )
                throw new \RuntimeException(sprintf(
                    'Channel (%s) is not present when trying to get size.'
                    , $queue
                ));

            $count = $qd->size($queue);
        }

        return $count;
    }
Get Queue Size

@param string $queue

@return int
@throws exIOError