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);