[jbpm-commits] JBoss JBPM SVN: r1948 - jbpm3/trunk/modules/enterprise/src/main/java/org/jbpm/scheduler/ejbtimer.

[do-not-reply at jboss.org]

Author: alex.guizar at 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);