[jboss-svn-commits] JBL Code SVN: r30252 - labs/jbossesb/trunk/product/services/jbpm/src/main/java/org/jboss/soa/esb/services/jbpm/configuration.

[jboss-svn-commits at lists.jboss.org]

Author: kevin.conner at jboss.com
Date: 2009-11-19 08:59:04 -0500 (Thu, 19 Nov 2009)
New Revision: 30252

Modified:
   labs/jbossesb/trunk/product/services/jbpm/src/main/java/org/jboss/soa/esb/services/jbpm/configuration/JbpmService.java
Log:
Check for existence of JobExecutor, force start/stop of services: JBESB-2986

Modified: labs/jbossesb/trunk/product/services/jbpm/src/main/java/org/jboss/soa/esb/services/jbpm/configuration/JbpmService.java
===================================================================
--- labs/jbossesb/trunk/product/services/jbpm/src/main/java/org/jboss/soa/esb/services/jbpm/configuration/JbpmService.java	2009-11-19 13:54:23 UTC (rev 30251)
+++ labs/jbossesb/trunk/product/services/jbpm/src/main/java/org/jboss/soa/esb/services/jbpm/configuration/JbpmService.java	2009-11-19 13:59:04 UTC (rev 30252)
@@ -23,6 +23,8 @@
 
 import org.jboss.system.ServiceMBeanSupport;
 import org.jbpm.JbpmConfiguration;
+import org.jbpm.JbpmContext;
+import org.jbpm.job.executor.JobExecutor;
 
 /**
  * MBean controlling the jBPM service initialisation.
@@ -39,7 +41,13 @@
         throws Exception
     {
         final JbpmConfiguration jbpmConfiguration = JbpmConfiguration.getInstance() ;
-        jbpmConfiguration.getJobExecutor().start() ;
+        final JobExecutor jobExecutor = jbpmConfiguration.getJobExecutor() ;
+        if (jobExecutor != null)
+        {
+            jobExecutor.start() ;
+        }
+        final JbpmContext jbpmContext = jbpmConfiguration.createJbpmContext() ;
+        jbpmContext.close() ;
         super.startService();
     }
 
@@ -49,6 +57,11 @@
     {
         super.stopService();
         final JbpmConfiguration jbpmConfiguration = JbpmConfiguration.getInstance() ;
-        jbpmConfiguration.getJobExecutor().stopAndJoin() ;
+        final JobExecutor jobExecutor = jbpmConfiguration.getJobExecutor() ;
+        if (jobExecutor != null)
+        {
+            jobExecutor.stopAndJoin() ;
+        }
+        jbpmConfiguration.close() ;
     }
 }