[jboss-svn-commits] JBL Code SVN: r27115 - labs/jbossesb/branches/JBESB_4_4_GA_CP/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-06-24 07:40:18 -0400 (Wed, 24 Jun 2009)
New Revision: 27115

Modified:
   labs/jbossesb/branches/JBESB_4_4_GA_CP/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-2642

Modified: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/services/jbpm/src/main/java/org/jboss/soa/esb/services/jbpm/configuration/JbpmService.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_4_GA_CP/product/services/jbpm/src/main/java/org/jboss/soa/esb/services/jbpm/configuration/JbpmService.java	2009-06-24 11:37:01 UTC (rev 27114)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/services/jbpm/src/main/java/org/jboss/soa/esb/services/jbpm/configuration/JbpmService.java	2009-06-24 11:40:18 UTC (rev 27115)
@@ -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() ;
     }
 }