From 378deb72b0cc829ae06d96fc924859c4eee08c8b Mon Sep 17 00:00:00 2001 From: Debasish Ghosh Date: Fri, 12 Nov 2010 10:02:58 +0530 Subject: [PATCH] updated test case to ensure that sorted sets have diff scores --- .../src/test/scala/RedisTicket513Spec.scala | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/akka-persistence/akka-persistence-redis/src/test/scala/RedisTicket513Spec.scala b/akka-persistence/akka-persistence-redis/src/test/scala/RedisTicket513Spec.scala index 66e08f2c98..0a58592045 100644 --- a/akka-persistence/akka-persistence-redis/src/test/scala/RedisTicket513Spec.scala +++ b/akka-persistence/akka-persistence-redis/src/test/scala/RedisTicket513Spec.scala @@ -17,12 +17,12 @@ import Actor._ * @author Debasish Ghosh */ -case class Add(email: String, value: String) +case class AddEmail(email: String, value: String) case class GetAll(email: String) class MySortedSet extends Transactor { def receive = { - case Add(userEmail, value) => { + case AddEmail(userEmail, value) => { val registryId = "userValues:%s".format(userEmail) val storageSet = RedisStorage.getSortedSet(registryId) storageSet.add(value.getBytes, System.nanoTime.toFloat) @@ -58,8 +58,9 @@ class RedisTicket513Spec extends val a = actorOf[MySortedSet] a.start it("should work with transactors") { - (a !! Add("test.user@gmail.com", "foo")).get should equal(1) - (a !! Add("test.user@gmail.com", "bar")).get should equal(2) + (a !! AddEmail("test.user@gmail.com", "foo")).get should equal(1) + Thread.sleep(10) + (a !! AddEmail("test.user@gmail.com", "bar")).get should equal(2) (a !! GetAll("test.user@gmail.com")).get.asInstanceOf[List[_]].size should equal(2) } }