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

Queue storage is only implemented in Redis. Base trait throws UnsupportedOperationException

Browse source
This commit is contained in:
debasishg 2010-01-13 10:25:32 +05:30
parent 9f12d05def
commit 596c576cb7
2 changed files with 9 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

9
akka-persistence/akka-persistence-common/src/main/scala/Storage.scala
View file

@ -48,17 +48,20 @@ trait Storage {
def newMap: PersistentMap[ElementType, ElementType]
def newVector: PersistentVector[ElementType]
def newRef: PersistentRef[ElementType]
def newQueue: PersistentQueue[ElementType]
def newQueue: PersistentQueue[ElementType] = // only implemented for redis
throw new UnsupportedOperationException
def getMap(id: String): PersistentMap[ElementType, ElementType]
def getVector(id: String): PersistentVector[ElementType]
def getRef(id: String): PersistentRef[ElementType]
def getQueue(id: String): PersistentQueue[ElementType]
def getQueue(id: String): PersistentQueue[ElementType] = // only implemented for redis
throw new UnsupportedOperationException
def newMap(id: String): PersistentMap[ElementType, ElementType]
def newVector(id: String): PersistentVector[ElementType]
def newRef(id: String): PersistentRef[ElementType]
def newQueue(id: String): PersistentQueue[ElementType]
def newQueue(id: String): PersistentQueue[ElementType] = // only implemented for redis
throw new UnsupportedOperationException
}

6
akka-persistence/akka-persistence-redis/src/main/scala/RedisStorage.scala
View file

@ -12,17 +12,17 @@ object RedisStorage extends Storage {
def newMap: PersistentMap[ElementType, ElementType] = newMap(Uuid.newUuid.toString)
def newVector: PersistentVector[ElementType] = newVector(Uuid.newUuid.toString)
def newRef: PersistentRef[ElementType] = newRef(Uuid.newUuid.toString)
def newQueue: PersistentQueue[ElementType] = newQueue(Uuid.newUuid.toString)
override def newQueue: PersistentQueue[ElementType] = newQueue(Uuid.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)
def getQueue(id: String): PersistentQueue[ElementType] = newQueue(id)
override def getQueue(id: String): PersistentQueue[ElementType] = newQueue(id)
def newMap(id: String): PersistentMap[ElementType, ElementType] = new RedisPersistentMap(id)
def newVector(id: String): PersistentVector[ElementType] = new RedisPersistentVector(id)
def newRef(id: String): PersistentRef[ElementType] = new RedisPersistentRef(id)
def newQueue(id: String): PersistentQueue[ElementType] = new RedisPersistentQueue(id)
override def newQueue(id: String): PersistentQueue[ElementType] = new RedisPersistentQueue(id)
}
/**