'Create a new `queue` if the `queue` doesn\'t already exist.
Arguments:
queue (str): The name of the queue.'

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

    self.queues[queue] = queue
    with self._queue_lock(queue):
        try:
            return self.client.write(key=self._key_prefix(queue), dir=True, value=None)
        except etcd.EtcdNotFile:
            logger.debug(u'Queue    "{0}"    already    exists'.format(queue))
            return self.client.read(key=self._key_prefix(queue))
