[jbpm-commits] JBoss JBPM SVN: r1948 - jbpm3/trunk/modules/enterprise/src/main/java/org/jbpm/scheduler/ejbtimer.
Author: alex.guizar(a)jboss.com
Date: 2008-08-21 03:28:15 -0400 (Thu, 21 Aug 2008)
New Revision: 1948
Modified:
jbpm3/trunk/modules/enterprise/src/main/java/org/jbpm/scheduler/ejbtimer/EntitySchedulerService.java
Log:
added session flush after saving job: JBPM-1620
Modified:
jbpm3/trunk/modules/enterprise/src/main/java/org/jbpm/scheduler/ejbtimer/EntitySchedulerService.java
===================================================================
---
jbpm3/trunk/modules/enterprise/src/main/java/org/jbpm/scheduler/ejbtimer/EntitySchedulerService.java 2008-08-21
05:15:18 UTC (rev 1947)
+++
jbpm3/trunk/modules/enterprise/src/main/java/org/jbpm/scheduler/ejbtimer/EntitySchedulerService.java 2008-08-21
07:28:15 UTC (rev 1948)
@@ -7,6 +7,7 @@
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
+import org.hibernate.Session;
import org.jbpm.JbpmContext;
import org.jbpm.JbpmException;
import org.jbpm.db.JobSession;
@@ -22,6 +23,7 @@
private static final long serialVersionUID = 1L;
JobSession jobSession;
+ Session session;
LocalTimerEntityHome timerEntityHome;
public EntitySchedulerService(LocalTimerEntityHome timerEntityHome) {
@@ -31,12 +33,14 @@
"instantiation of the EjbSchedulerService requires a current
JbpmContext");
}
this.jobSession = jbpmContext.getJobSession();
+ this.session = jbpmContext.getSession();
this.timerEntityHome = timerEntityHome;
}
public void createTimer(Timer timer) {
log.debug("creating timer " + timer);
jobSession.saveJob(timer);
+ session.flush();
try {
LocalTimerEntity timerEntity = timerEntityHome.findByPrimaryKey(new
Long(timer.getId()));
timerEntity.createTimer(timer);