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

Fixed Issue 528 - RedisPersistentRef should not throw in case of missing key

Browse source
This commit is contained in:
Debasish Ghosh 2010-11-13 22:02:35 +05:30
parent ac1baa8143
commit 2c9feef4cd
2 changed files with 1 additions and 18 deletions
Download patch file Download diff file Expand all files Collapse all files

3
akka-persistence/akka-persistence-redis/src/main/scala/RedisStorageBackend.scala
View file

@ -248,9 +248,6 @@ private [akka] object RedisStorageBackend extends
def getRefStorageFor(name: String): Option[Array[Byte]] = withErrorHandling {
db.get(name)
.map(stringToByteArray(_))
.orElse {
throw new NoSuchElementException(name + " not present")
}
}
// add to the end of the queue

16
akka-persistence/akka-persistence-redis/src/test/scala/RedisStorageBackendSpec.scala
View file

@ -153,6 +153,7 @@ class RedisStorageBackendSpec extends
insertRefStorageFor("T-4", "1200".getBytes)
new String(getRefStorageFor("T-4").get) should equal("1200")
getRefStorageFor("T-44") should equal(None)
}
it("should write a Name object and fetch it properly") {
val dtb = Calendar.getInstance.getTime
@ -226,21 +227,6 @@ class RedisStorageBackendSpec extends
u.map{ case (e, s) => new String(e) } should equal(sorted)
}
}
describe("store and query test in sorted set") {
it("should give proper sorted set semantics") {
zadd("hckers", "1965", "yukihiro matsumoto".getBytes)
zadd("hckers", "1953", "richard stallman".getBytes)
zadd("hckers", "1916", "claude shannon".getBytes)
zadd("hckers", "1969", "linus torvalds".getBytes)
zadd("hckers", "1940", "alan kay".getBytes)
zadd("hckers", "1912", "alan turing".getBytes)
zadd("hckers", "1912", "debasish ghosh".getBytes)
println(zcard("hckers"))
println(zrange("hckers", 0, -1))
}
}
}
object NameSerialization {