'Ensure a queue exists in SLQS.'

def _new_queue(self, queue, **kwargs):

    queue = self.entity_name((self.queue_name_prefix + queue))
    try:
        return self._queue_cache[queue]
    except KeyError:
        try:
            self.slmq.create_queue(queue, visibility_timeout=self.visibility_timeout)
        except ResponseError:
            pass
        q = self._queue_cache[queue] = self.slmq.queue(queue)
        return q
