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

Update new redis tests

Browse source
This commit is contained in:
Peter Vlugter 2010-11-13 12:15:53 +13:00
parent 489c3a54b8
commit a07a85a04f
1 changed files with 6 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

9
akka-persistence/akka-persistence-redis/src/test/scala/RedisTicket513Spec.scala
View file

@ -7,8 +7,9 @@ import org.scalatest.BeforeAndAfterAll
import org.scalatest.junit.JUnitRunner
import org.junit.runner.RunWith
import akka.actor.{Actor, ActorRef, Transactor}
import akka.actor.{Actor, ActorRef}
import Actor._
import akka.stm._
/**
* A persistent actor based on Redis sortedset storage.
@ -20,9 +21,11 @@ import Actor._
case class AddEmail(email: String, value: String)
case class GetAll(email: String)
class MySortedSet extends Transactor {
class MySortedSet extends Actor {
def receive = {
def receive = { case message => atomic { atomicReceive(message) } }
def atomicReceive: Receive = {
case AddEmail(userEmail, value) => {
val registryId = "userValues:%s".format(userEmail)
val storageSet = RedisStorage.getSortedSet(registryId)