'Remove all `message`s from a `queue`.
Arguments:
queue (str): The name of the queue.'

def _purge(self, queue):

    with self._queue_lock(queue):
        key = self._key_prefix(queue)
        logger.debug(u'Purging    queue    at    key    {0}'.format(key))
        return self.client.delete(key=key, recursive=True)
