diff --git a/akka-core/src/test/scala/StmSpec.scala b/akka-core/src/test/scala/StmSpec.scala index 667b4b8df4..f9ce0c7366 100644 --- a/akka-core/src/test/scala/StmSpec.scala +++ b/akka-core/src/test/scala/StmSpec.scala @@ -81,5 +81,33 @@ class StmSpec extends } total should equal(0) } + + it("should be able to initialize with atomic block inside actor constructor") { + try { + val actor = actorOf[StmTestActor] + } catch { + case e => fail(e.toString) + } + } } } + +class StmTestActor extends Actor { + import se.scalablesolutions.akka.persistence.redis.RedisStorage + import se.scalablesolutions.akka.stm.Transaction.Global + private var eventLog = Global.atomic { RedisStorage.getVector("log") } + + def receive = { case _ => () } + /* + case msg @ EnrichTrade(trade) => + atomic { eventLog + msg.toString.getBytes("UTF-8") } + + case msg @ ValueTrade(trade) => + atomic { eventLog + msg.toString.getBytes("UTF-8") } + + case GetEventLog(trade) => + val eventList = atomic { eventLog.map(bytes => new String(bytes, "UTF-8")).toList } + reply(EventLog(eventList)) + } + */ +} diff --git a/akka-fun-test-java/pom.xml b/akka-fun-test-java/pom.xml index c4851757c1..c8ddef3320 100644 --- a/akka-fun-test-java/pom.xml +++ b/akka-fun-test-java/pom.xml @@ -6,26 +6,42 @@ Akka Functional Tests in Java akka-fun-test-java se.scalablesolutions.akka - 0.7 + 0.9 jar - 2.7.7 + 2.8.0.RC2 0.5.2 1.1.5 1.9.18-i + + + embedded-repo + Embedded Repository + file://Users/jboner/src/scala/akka/embedded-repo + + + + + + scala-tools.org + Scala-Tools Maven2 Repository + http://scala-tools.org/repo-releases + + + se.scalablesolutions.akka - akka-kernel_2.7.7 - 0.7 + akka-kernel_2.8.0.RC2 + 0.9 se.scalablesolutions.akka - akka-persistence-cassandra_2.7.7 - 0.7 + akka-persistence-cassandra_2.8.0.RC2 + 0.9 com.google.protobuf