From 975cdc7117a8716cbdf8482e8d4b4d6ba61440ef Mon Sep 17 00:00:00 2001 From: ticktock Date: Tue, 26 Oct 2010 21:05:53 -0400 Subject: [PATCH] Adding PersistentQueue to CassandraStorage --- .../src/main/scala/CassandraStorage.scala | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/akka-persistence/akka-persistence-cassandra/src/main/scala/CassandraStorage.scala b/akka-persistence/akka-persistence-cassandra/src/main/scala/CassandraStorage.scala index b3867b9492..3cb99fbc33 100644 --- a/akka-persistence/akka-persistence-cassandra/src/main/scala/CassandraStorage.scala +++ b/akka-persistence/akka-persistence-cassandra/src/main/scala/CassandraStorage.scala @@ -14,14 +14,17 @@ object CassandraStorage extends Storage { def newMap: PersistentMap[ElementType, ElementType] = newMap(newUuid.toString) def newVector: PersistentVector[ElementType] = newVector(newUuid.toString) def newRef: PersistentRef[ElementType] = newRef(newUuid.toString) + override def newQueue: PersistentQueue[ElementType] = newQueue(newUuid.toString) def getMap(id: String): PersistentMap[ElementType, ElementType] = newMap(id) def getVector(id: String): PersistentVector[ElementType] = newVector(id) def getRef(id: String): PersistentRef[ElementType] = newRef(id) + override def getQueue(id: String): PersistentQueue[ElementType] = newQueue(id) def newMap(id: String): PersistentMap[ElementType, ElementType] = new CassandraPersistentMap(id) def newVector(id: String): PersistentVector[ElementType] = new CassandraPersistentVector(id) def newRef(id: String): PersistentRef[ElementType] = new CassandraPersistentRef(id) + override def newQueue(id: String): PersistentQueue[ElementType] = new CassandraPersistentQueue(id) } /** @@ -49,3 +52,8 @@ class CassandraPersistentRef(id: String) extends PersistentRef[Array[Byte]] { val uuid = id val storage = CassandraStorageBackend } + +class CassandraPersistentQueue(id: String) extends PersistentQueue[Array[Byte]] { + val uuid = id + val storage = CassandraStorageBackend +}