diff --git a/ivy.xml b/ivy.xml index ab586e7..c70d5ba 100644 --- a/ivy.xml +++ b/ivy.xml @@ -38,7 +38,7 @@ - + diff --git a/src/lucandra/CassandraUtils.java b/src/lucandra/CassandraUtils.java index df9b06a..146bfd9 100644 --- a/src/lucandra/CassandraUtils.java +++ b/src/lucandra/CassandraUtils.java @@ -34,7 +34,7 @@ import java.util.zip.Inflater; import org.apache.cassandra.config.ConfigurationException; -import org.apache.cassandra.config.DatabaseDescriptor; +import org.apache.cassandra.config.Schema; import org.apache.cassandra.db.*; import org.apache.cassandra.db.filter.QueryPath; import org.apache.cassandra.service.AbstractCassandraDaemon; @@ -307,7 +307,7 @@ public static void createCassandraSchema() throws IOException return; } - if (DatabaseDescriptor.getNonSystemTables().contains(keySpace)) + if (Schema.instance.getNonSystemTables().contains(keySpace)) { logger.info("Found Solandra specific schema"); return; @@ -329,7 +329,7 @@ public static void createCassandraSchema() throws IOException System.exit(2); } - if (DatabaseDescriptor.getNonSystemTables().contains(keySpace)) + if (Schema.instance.getNonSystemTables().contains(keySpace)) { logger.info("Found Solandra specific schema"); return; diff --git a/src/solandra/SolandraComponent.java b/src/solandra/SolandraComponent.java index 8cc7ef7..cb498e5 100644 --- a/src/solandra/SolandraComponent.java +++ b/src/solandra/SolandraComponent.java @@ -35,6 +35,7 @@ import com.google.common.collect.MapMaker; import org.apache.cassandra.config.DatabaseDescriptor; +import org.apache.cassandra.config.Schema; import org.apache.cassandra.db.Row; import org.apache.cassandra.db.filter.QueryPath; import org.apache.cassandra.service.StorageService; @@ -93,7 +94,7 @@ public static boolean prepare(ResponseBuilder rb) throws IOException if(!hasSolandraSchema.get()) { //Check is Solandra schema exists, if not die - if(! DatabaseDescriptor.getNonSystemTables().contains(CassandraUtils.keySpace) ) + if(! Schema.instance.getNonSystemTables().contains(CassandraUtils.keySpace) ) throw new IOException("Solandra keyspace is missing, please import then retry"); else hasSolandraSchema.set(true);