schema_init.java

    private void initSchema() {
        doWithLock("cassalog", () -> {
                SchemaService schemaService = new SchemaService();
                schemaService.run(session, keyspace, Boolean.parseBoolean(resetDb));
                session.execute("USE " + keyspace);
        });
    }

    private void doWithLock(String key, Runnable runnable) {
        AdvancedCache<String, String> cache = locksCache.getAdvancedCache();
        DistributedLock schemaLock = new DistributedLock(cache);

        try {
            schemaLock.lock();
            while (!schemaLock.isLocked()) {
                log.info("Failed to acquire schema lock. Trying again in 10 seconds.");
                Thread.sleep(10000);
                schemaLock.lock();
            }
            runnable.run();
        } catch (Throwable t) {
            throw new RuntimeException(t);
        } finally {
            schemaLock.release();
        }
    }