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

Made JTA Synchronization management generic and allowing more than one + refactoring

Browse source
This commit is contained in:
Jonas Bonér 2010-04-21 11:18:07 +02:00
parent 628e5530a1
commit 559689d082
4 changed files with 70 additions and 39 deletions
Download patch file Download diff file Expand all files Collapse all files

8
akka-core/src/main/scala/stm/Transaction.scala
View file

@ -316,13 +316,7 @@ object Transaction {
def begin = synchronized {
jta.foreach { txContainer =>
txContainer.begin
TransactionContainer.findSynchronizationRegistry match {
case Some(registry) =>
registry.asInstanceOf[TransactionSynchronizationRegistry].registerInterposedSynchronization(
new StmSynchronization(txContainer, this))
case None =>
log.warning("Cannot find TransactionSynchronizationRegistry in JNDI, can't register STM synchronization")
}
txContainer.registerSynchronization(new StmSynchronization(txContainer, this))
}
}