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

Move Transactor and Coordinated to akka.transactor package

Browse source
This commit is contained in:
Peter Vlugter 2010-11-09 15:16:38 +13:00
parent 8d5be782eb
commit 2cbd033a45
5 changed files with 13 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

3
akka-stm/src/main/scala/stm/Coordinated.scala → akka-stm/src/main/scala/transactor/Coordinated.scala
View file

@ -2,9 +2,10 @@
* Copyright (C) 2009-2010 Scalable Solutions AB <http://scalablesolutions.se>
*/
package akka.stm
package akka.transactor
import akka.config.Config
import akka.stm.{DefaultTransactionConfig, TransactionFactory}
import org.multiverse.api.{Transaction => MultiverseTransaction}
import org.multiverse.commitbarriers.CountDownCommitBarrier

7
akka-stm/src/main/scala/actor/Transactor.scala → akka-stm/src/main/scala/transactor/Transactor.scala
View file

@ -2,9 +2,10 @@
* Copyright (C) 2009-2010 Scalable Solutions AB <http://scalablesolutions.se>
*/
package akka.actor
package akka.transactor
import akka.stm.{Coordinated, DefaultTransactionConfig, TransactionFactory}
import akka.actor.{Actor, ActorRef}
import akka.stm.{DefaultTransactionConfig, TransactionFactory}
/**
* Transactor. See companion class for information.
@ -111,7 +112,7 @@ trait Transactor extends Actor {
/**
* Implement a general pattern for using coordinated transactions.
*/
def receive = {
final def receive = {
case coordinated @ Coordinated(message) => {
val others = (coordinate orElse alone)(message)
for (sendTo <- others) {

3
akka-stm/src/test/scala/stm/CoordinatedIncrementSpec.scala → akka-stm/src/test/scala/transactor/CoordinatedIncrementSpec.scala
View file

@ -1,8 +1,9 @@
package akka.stm.test
package akka.transactor.test
import org.scalatest.WordSpec
import org.scalatest.matchers.MustMatchers
import akka.transactor.Coordinated
import akka.actor.{Actor, ActorRef}
import akka.stm._
import akka.util.duration._

3
akka-stm/src/test/scala/stm/FickleFriendsSpec.scala → akka-stm/src/test/scala/transactor/FickleFriendsSpec.scala
View file

@ -1,8 +1,9 @@
package akka.stm.test
package akka.transactor.test
import org.scalatest.WordSpec
import org.scalatest.matchers.MustMatchers
import akka.transactor.Coordinated
import akka.actor.{Actor, ActorRef}
import akka.stm._
import akka.util.duration._

5
akka-stm/src/test/scala/actor/TransactorSpec.scala → akka-stm/src/test/scala/transactor/TransactorSpec.scala
View file

@ -1,9 +1,10 @@
package akka.actor.test
package akka.transactor.test
import org.scalatest.WordSpec
import org.scalatest.matchers.MustMatchers
import akka.actor.{Transactor, Actor, ActorRef}
import akka.transactor.Transactor
import akka.actor.{Actor, ActorRef}
import akka.stm._
import akka.util.duration._