From a07a85a04f03be44c012e88ade6710892c59fead Mon Sep 17 00:00:00 2001
From: Peter Vlugter <peter@maka>
Date: Sat, 13 Nov 2010 12:15:53 +1300
Subject: [PATCH] Update new redis tests

---
 .../src/test/scala/RedisTicket513Spec.scala              | 9 ++++++---
 1 file changed, 6 insertions(+), 3 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 8dc38324d6..a09fe54b16 100644
--- a/akka-persistence/akka-persistence-redis/src/test/scala/RedisTicket513Spec.scala
+++ b/akka-persistence/akka-persistence-redis/src/test/scala/RedisTicket513Spec.scala
@@ -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)