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