raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Adding PersistentQueue to CassandraStorage

Browse source
This commit is contained in:
ticktock 2010-10-26 21:05:53 -04:00
parent 4b075391e6
commit 975cdc7117
1 changed files with 8 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

8
akka-persistence/akka-persistence-cassandra/src/main/scala/CassandraStorage.scala
View file

@ -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
}