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

Added support for MaximumNumberOfRestartsWithinTimeRangeReachedException(this, maxNrOfRetries, withinTimeRange, reason)

Browse source
This commit is contained in:
Jonas Bonér 2010-07-15 12:49:21 +02:00
commit 333c0409fe
17 changed files with 230 additions and 98 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -149,14 +149,7 @@ class GlobalStm extends TransactionManagement with Logging {
def atomic[T](body: => T)(implicit factory: TransactionFactory = DefaultGlobalTransactionFactory): T = atomic(factory)(body)
def atomic[T](factory: TransactionFactory)(body: => T): T = {
/* MultiverseStmUtils.scheduleDeferredTask(new Runnable {
def run = try {
getTransactionSetInScope.tryJoinCommit(getRequiredThreadLocalTransaction, TransactionConfig.TIMEOUT, TimeUnit.MILLISECONDS)
clearTransaction
} catch {
case e: IllegalStateException => {}
}})
*/ factory.boilerplate.execute(new TransactionalCallable[T]() {
factory.boilerplate.execute(new TransactionalCallable[T]() {
def call(mtx: MultiverseTransaction): T = {
if (!isTransactionSetInScope) createNewTransactionSet
factory.addHooks
@ -166,7 +159,6 @@ class GlobalStm extends TransactionManagement with Logging {
mtx.commit
// Need to catch IllegalStateException until we have fix in Multiverse, since it throws it by mistake
try { txSet.tryJoinCommit(mtx, TransactionConfig.TIMEOUT, TimeUnit.MILLISECONDS) } catch { case e: IllegalStateException => {} }
// try { txSet.joinCommit(mtx) } catch { case e: IllegalStateException => {} }
result
}
})