diff --git a/akka-fun-test-java/src/test/java/se/scalablesolutions/akka/api/PersistentClasher.java b/akka-fun-test-java/src/test/java/se/scalablesolutions/akka/api/PersistentClasher.java index 1787548806..f7715d1a82 100644 --- a/akka-fun-test-java/src/test/java/se/scalablesolutions/akka/api/PersistentClasher.java +++ b/akka-fun-test-java/src/test/java/se/scalablesolutions/akka/api/PersistentClasher.java @@ -1,10 +1,9 @@ package se.scalablesolutions.akka.api; import se.scalablesolutions.akka.state.TransactionalMap; -import se.scalablesolutions.akka.state.CassandraPersistentTransactionalMap; public class PersistentClasher { - private TransactionalMap state = new CassandraPersistentTransactionalMap(); + private TransactionalMap state = new se.scalablesolutions.akka.state.CassandraPersistentMap(); public String getState(String key) { return (String)state.get(key).get(); diff --git a/akka-persistence/src/main/scala/PersistentState.scala b/akka-persistence/src/main/scala/PersistentState.scala index 75460cc47b..0b8bfb8fd1 100644 --- a/akka-persistence/src/main/scala/PersistentState.scala +++ b/akka-persistence/src/main/scala/PersistentState.scala @@ -39,22 +39,22 @@ object PersistentState extends PersistentState */ class PersistentState { def newMap(config: PersistentStorageConfig): TransactionalMap[AnyRef, AnyRef] = config match { - case CassandraStorageConfig() => new CassandraPersistentTransactionalMap - case MongoStorageConfig() => new MongoPersistentTransactionalMap + case CassandraStorageConfig() => new CassandraPersistentMap + case MongoStorageConfig() => new MongoPersistentMap case TerracottaStorageConfig() => throw new UnsupportedOperationException case TokyoCabinetStorageConfig() => throw new UnsupportedOperationException } def newVector(config: PersistentStorageConfig): TransactionalVector[AnyRef] = config match { - case CassandraStorageConfig() => new CassandraPersistentTransactionalVector - case MongoStorageConfig() => new MongoPersistentTransactionalVector + case CassandraStorageConfig() => new CassandraPersistentVector + case MongoStorageConfig() => new MongoPersistentVector case TerracottaStorageConfig() => throw new UnsupportedOperationException case TokyoCabinetStorageConfig() => throw new UnsupportedOperationException } def newRef(config: PersistentStorageConfig): TransactionalRef[AnyRef] = config match { - case CassandraStorageConfig() => new CassandraPersistentTransactionalRef - case MongoStorageConfig() => new MongoPersistentTransactionalRef + case CassandraStorageConfig() => new CassandraPersistentRef + case MongoStorageConfig() => new MongoPersistentRef case TerracottaStorageConfig() => throw new UnsupportedOperationException case TokyoCabinetStorageConfig() => throw new UnsupportedOperationException } @@ -68,7 +68,7 @@ class PersistentState { * * @author Jonas Bonér */ -abstract class PersistentTransactionalMap[K, V] extends TransactionalMap[K, V] { +abstract class PersistentMap[K, V] extends TransactionalMap[K, V] { // FIXME: need to handle remove in another changeSet protected[akka] val changeSet = new HashMap[K, V] @@ -93,7 +93,7 @@ abstract class PersistentTransactionalMap[K, V] extends TransactionalMap[K, V] { } /** - * Implementation of PersistentTransactionalMap for every concrete + * Implementation of PersistentMap for every concrete * storage will have the same workflow. This abstracts the workflow. * * Subclasses just need to provide the actual concrete instance for the @@ -101,7 +101,7 @@ abstract class PersistentTransactionalMap[K, V] extends TransactionalMap[K, V] { * * @author Jonas Bonér */ -abstract class TemplatePersistentTransactionalMap extends PersistentTransactionalMap[AnyRef, AnyRef] { +abstract class TemplatePersistentMap extends PersistentMap[AnyRef, AnyRef] { // to be concretized in subclasses val storage: MapStorage @@ -191,7 +191,7 @@ abstract class TemplatePersistentTransactionalMap extends PersistentTransactiona * * @author Debasish Ghosh */ -class CassandraPersistentTransactionalMap extends TemplatePersistentTransactionalMap { +class CassandraPersistentMap extends TemplatePersistentMap { val storage = CassandraStorage } @@ -200,7 +200,7 @@ class CassandraPersistentTransactionalMap extends TemplatePersistentTransactiona * * @author Debasish Ghosh */ -class MongoPersistentTransactionalMap extends TemplatePersistentTransactionalMap { +class MongoPersistentMap extends TemplatePersistentMap { val storage = MongoStorage } @@ -212,7 +212,7 @@ class MongoPersistentTransactionalMap extends TemplatePersistentTransactionalMap * * @author Jonas Bonér */ -abstract class PersistentTransactionalVector[T] extends TransactionalVector[T] { +abstract class PersistentVector[T] extends TransactionalVector[T] { // FIXME: need to handle remove in another changeSet protected[akka] val changeSet = new ArrayBuffer[T] @@ -234,7 +234,7 @@ abstract class PersistentTransactionalVector[T] extends TransactionalVector[T] { * * @author Debasish Ghosh */ -abstract class TemplatePersistentTransactionalVector extends PersistentTransactionalVector[AnyRef] { +abstract class TemplatePersistentVector extends PersistentVector[AnyRef] { val storage: VectorStorage @@ -282,7 +282,7 @@ abstract class TemplatePersistentTransactionalVector extends PersistentTransacti * * @author Debaissh Ghosh */ -class CassandraPersistentTransactionalVector extends TemplatePersistentTransactionalVector { +class CassandraPersistentVector extends TemplatePersistentVector { val storage = CassandraStorage } @@ -291,11 +291,11 @@ class CassandraPersistentTransactionalVector extends TemplatePersistentTransacti * * @author Debaissh Ghosh */ -class MongoPersistentTransactionalVector extends TemplatePersistentTransactionalVector { +class MongoPersistentVector extends TemplatePersistentVector { val storage = MongoStorage } -abstract class TemplatePersistentTransactionalRef extends TransactionalRef[AnyRef] { +abstract class TemplatePersistentRef extends TransactionalRef[AnyRef] { val storage: RefStorage override def commit = if (ref.isDefined) { @@ -319,10 +319,10 @@ abstract class TemplatePersistentTransactionalRef extends TransactionalRef[AnyRe } } -class CassandraPersistentTransactionalRef extends TemplatePersistentTransactionalRef { +class CassandraPersistentRef extends TemplatePersistentRef { val storage = CassandraStorage } -class MongoPersistentTransactionalRef extends TemplatePersistentTransactionalRef { +class MongoPersistentRef extends TemplatePersistentRef { val storage = MongoStorage }