src/test/java/com/thinkaurelius/titan/diskstorage/cassandra/thrift/ThriftIDAuthorityTest.java

   1 package com.thinkaurelius.titan.diskstorage.cassandra.thrift;
   2
   3 import com.thinkaurelius.titan.CassandraStorageSetup;
   4 import com.thinkaurelius.titan.diskstorage.BackendException;
   5 import com.thinkaurelius.titan.diskstorage.IDAuthorityTest;
   6 import com.thinkaurelius.titan.diskstorage.configuration.WriteConfiguration;
   7 import com.thinkaurelius.titan.diskstorage.keycolumnvalue.KeyColumnValueStoreManager;
   8 import org.junit.BeforeClass;
   9
  10 public class ThriftIDAuthorityTest extends IDAuthorityTest {
  11
  12     public ThriftIDAuthorityTest(WriteConfiguration baseConfig) {
  13         super(baseConfig);
  14     }
  15
  16     @BeforeClass
  17     public static void startCassandra() {
  18         CassandraStorageSetup.startCleanEmbedded();
  19     }
  20
  21     @Override
  22     public KeyColumnValueStoreManager openStorageManager() throws BackendException {
  23         return new CassandraThriftStoreManager(CassandraStorageSetup.getCassandraThriftConfiguration(this.getClass().getSimpleName()));
  24     }
  25 }