CassandraTransaction extends AbstractStoreTransaction { public CLevel getWriteConsistencyLevel() { return write; } CassandraTransaction(BaseTransactionConfig c); CLevel getReadConsistencyLevel(); CLevel getWriteConsistencyLevel(); static CassandraTransaction getTx(StoreTransaction txh); String toString();  }
@Test public void testWriteConsistencyLevel() { int levelsChecked = 0; for (CLevel writeLevel : CLevel.values()) { StandardBaseTransactionConfig.Builder b = new StandardBaseTransactionConfig.Builder(); ModifiableConfiguration mc = GraphDatabaseConfiguration.buildGraphConfiguration(); mc.set(CASSANDRA_WRITE_CONSISTENCY, writeLevel.name()); b.customOptions(mc); b.timestampProvider(TimestampProviders.MICRO); CassandraTransaction ct = new CassandraTransaction(b.build()); assertEquals(writeLevel, ct.getWriteConsistencyLevel()); levelsChecked++; } Preconditions.checkState(0 < levelsChecked); }