[jbpm-commits] JBoss JBPM SVN: r1870 - jbpm4/pvm/trunk/modules/core/src/test/java/org/jbpm/pvm/internal/jobexecutor.

[do-not-reply at jboss.org]

Author: porcherg
Date: 2008-08-12 06:25:29 -0400 (Tue, 12 Aug 2008)
New Revision: 1870

Modified:
   jbpm4/pvm/trunk/modules/core/src/test/java/org/jbpm/pvm/internal/jobexecutor/JobExecutorTest.java
Log:
use a command for areJobsAvailable() (the transaction was never completed)

Modified: jbpm4/pvm/trunk/modules/core/src/test/java/org/jbpm/pvm/internal/jobexecutor/JobExecutorTest.java
===================================================================
--- jbpm4/pvm/trunk/modules/core/src/test/java/org/jbpm/pvm/internal/jobexecutor/JobExecutorTest.java	2008-08-12 10:23:37 UTC (rev 1869)
+++ jbpm4/pvm/trunk/modules/core/src/test/java/org/jbpm/pvm/internal/jobexecutor/JobExecutorTest.java	2008-08-12 10:25:29 UTC (rev 1870)
@@ -284,22 +284,17 @@
   }
 
   boolean areJobsAvailable() {
-    Environment environment = getEnvironmentFactory().openEnvironment();
-    try {
-      JobDbSession jobDbSession = environment.get(JobDbSession.class);
-      
-      JobImpl<?> firstAcquirableJob = jobDbSession.findFirstAcquirableJob();
-      if (firstAcquirableJob!=null) {
-        log.debug("found more jobs to process");
-        return true;
+    return commandService.execute(new Command<Boolean>() {
+      public Boolean execute(Environment environment) throws Exception {
+        JobDbSession jobDbSession = environment.get(JobDbSession.class);
+        
+        JobImpl<?> firstAcquirableJob = jobDbSession.findFirstAcquirableJob();
+        if (firstAcquirableJob!=null) {
+          log.debug("found more jobs to process");
+          return true;
+        }
+        return false;
       }
-    } catch (RuntimeException e) {
-      environment.get(Transaction.class).setRollbackOnly();
-      throw e;
-    } finally {
-      environment.close();
-    }
-    log.debug("no more jobs to process");
-    return false;
+    });
   }
 }