[jbpm-commits] JBoss JBPM SVN: r2411 - jbpm3/branches/aguizar/modules/core/src/main/java/org/jbpm/db.

do-not-reply at jboss.org do-not-reply at jboss.org
Sun Sep 28 00:50:38 EDT 2008


Author: alex.guizar at jboss.com
Date: 2008-09-28 00:50:38 -0400 (Sun, 28 Sep 2008)
New Revision: 2411

Modified:
   jbpm3/branches/aguizar/modules/core/src/main/java/org/jbpm/db/JobSession.java
Log:
removing pessimistic locks on jobs, it does not help

Modified: jbpm3/branches/aguizar/modules/core/src/main/java/org/jbpm/db/JobSession.java
===================================================================
--- jbpm3/branches/aguizar/modules/core/src/main/java/org/jbpm/db/JobSession.java	2008-09-27 20:52:42 UTC (rev 2410)
+++ jbpm3/branches/aguizar/modules/core/src/main/java/org/jbpm/db/JobSession.java	2008-09-28 04:50:38 UTC (rev 2411)
@@ -6,7 +6,6 @@
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
-import org.hibernate.LockMode;
 import org.hibernate.Query;
 import org.hibernate.Session;
 import org.jbpm.JbpmContext;
@@ -33,7 +32,6 @@
       query.setString("lockOwner", lockOwner);
       query.setTimestamp("now", new Date());
       query.setMaxResults(1);
-      query.setLockMode("job", LockMode.UPGRADE);
       job = (Job) query.uniqueResult();
 
     } catch (Exception e) {
@@ -50,7 +48,6 @@
       query.setString("lockOwner", lockOwner);
       query.setTimestamp("now", new Date());
       query.setParameter("processInstance", processInstance);
-      query.setLockMode("job", LockMode.UPGRADE);
       jobs = query.list();
 
     } catch (Exception e) {
@@ -104,7 +101,7 @@
 
   public Job loadJob(long jobId) {
     try {
-      return (Job) session.load(Job.class, new Long(jobId), LockMode.UPGRADE);
+      return (Job) session.load(Job.class, new Long(jobId));
     } catch (Exception e) {
       log.error(e);
       throw new JbpmException("couldn't load job '"+jobId+"'", e);




More information about the jbpm-commits mailing list