[jbpm-commits] JBoss JBPM SVN: r5122 - jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/tx.
do-not-reply at jboss.org
do-not-reply at jboss.org
Thu Jun 25 09:49:50 EDT 2009
Author: ainze
Date: 2009-06-25 09:49:50 -0400 (Thu, 25 Jun 2009)
New Revision: 5122
Modified:
jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/tx/SpringTransactionInterceptor.java
Log:
timer support
Modified: jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/tx/SpringTransactionInterceptor.java
===================================================================
--- jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/tx/SpringTransactionInterceptor.java 2009-06-25 13:22:08 UTC (rev 5121)
+++ jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/tx/SpringTransactionInterceptor.java 2009-06-25 13:49:50 UTC (rev 5122)
@@ -67,8 +67,11 @@
try {
DefaultTransactionDefinition definition = new DefaultTransactionDefinition();
+
if (useCurrent) {
definition.setPropagationBehavior(TransactionDefinition.PROPAGATION_MANDATORY);
+ } else {
+ definition.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
}
TransactionTemplate template = new TransactionTemplate(platformTransactionManager, definition);
@@ -76,7 +79,10 @@
T t = (T) template.execute(transactionCallback);
Session session = environment.get(Session.class);
- session.flush();
+
+ if (session.isOpen()) {
+ session.flush();
+ }
return t;
} catch (RuntimeException e) {
if (standardTransaction != null) {
More information about the jbpm-commits
mailing list