public function setupQueue($queueName, $channel)
    {

        foreach ($this->queueOptions as $queue => $queueOption) {
            if ($queueOption['name'] == $queueName) {
                $status = $channel->queue_declare(
                    $queueName,
                    $queueOption['passive'],
                    $queueOption['durable'],
                    $queueOption['exclusive'],
                    $queueOption['auto_delete']
                );
                return array($channel, $status);
            }
        }

        // Error as queue has not been setup
        throw new Exception($queueName . ' options not found in $this->queueOptions.');
    }