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

Removed isTransactionalityEnabled

Browse source
This commit is contained in:
Peter Vlugter 2010-06-20 10:10:09 +12:00
parent 18ed80b160
commit 71fedd9128
3 changed files with 3 additions and 28 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-core/src/main/scala/stm/TransactionManagement.scala
View file

@ -23,15 +23,9 @@ class TransactionAwareWrapperException(val cause: Throwable, val tx: Option[Tran
object TransactionManagement extends TransactionManagement {
import se.scalablesolutions.akka.config.Config._
// is this needed?
val TRANSACTION_ENABLED = new AtomicBoolean(config.getBool("akka.stm.service", true))
// move to stm.global.fair?
val FAIR_TRANSACTIONS = config.getBool("akka.stm.fair", true)
def isTransactionalityEnabled = TRANSACTION_ENABLED.get
def disableTransactions = TRANSACTION_ENABLED.set(false)
private[akka] val transactionSet = new ThreadLocal[Option[CountDownCommitBarrier]]() {
override protected def initialValue: Option[CountDownCommitBarrier] = None
}