'Helper method to quickly get a queue.'

def _get_q(self, url):

    for q in self._queues.values():
        if (q.url == url):
            return q
    raise Exception(u'Queue    url    {}    not    found'.format(url))
