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

Updated copyright header

Browse source
This commit is contained in:
Jonas Bonér 2009-12-27 16:01:53 +01:00
parent ac5451a9fa
commit 90451b4f03
146 changed files with 152 additions and 153 deletions
Download patch file Download diff file Expand all files Collapse all files

7
akka-persistence-redis/src/test/scala/RedisPersistentActorTest.scala
View file

@ -5,7 +5,7 @@ import junit.framework.TestCase
import org.junit.{Test, Before}
import org.junit.Assert._
import se.scalablesolutions.akka.actor.Actor
import se.scalablesolutions.akka.actor.Transactor
/**
* A persistent actor based on Redis storage.
@ -26,12 +26,11 @@ case class MultiDebit(accountNo: String, amounts: List[BigInt], failer: Actor)
case class Credit(accountNo: String, amount: BigInt)
case object LogSize
class AccountActor extends Actor {
makeTransactionRequired
class AccountActor extends Transactor {
private val accountState = RedisStorage.newMap
private val txnLog = RedisStorage.newVector
def receive: PartialFunction[Any, Unit] = {
def receive = {
// check balance
case Balance(accountNo) =>
txnLog.add("Balance:%s".format(accountNo).getBytes)