[jboss-svn-commits] JBL Code SVN: r27114 - labs/jbossesb/branches/JBESB_4_4_GA_CP/product/services/jbpm/src/main/java/org/jboss/soa/esb/services/jbpm/cmd.

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

Author: kevin.conner at jboss.com
Date: 2009-06-24 07:37:01 -0400 (Wed, 24 Jun 2009)
New Revision: 27114

Modified:
   labs/jbossesb/branches/JBESB_4_4_GA_CP/product/services/jbpm/src/main/java/org/jboss/soa/esb/services/jbpm/cmd/AsyncProcessSignal.java
Log:
Check for JobExecutor existence: JBESB-2641

Modified: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/services/jbpm/src/main/java/org/jboss/soa/esb/services/jbpm/cmd/AsyncProcessSignal.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_4_GA_CP/product/services/jbpm/src/main/java/org/jboss/soa/esb/services/jbpm/cmd/AsyncProcessSignal.java	2009-06-24 11:27:08 UTC (rev 27113)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/services/jbpm/src/main/java/org/jboss/soa/esb/services/jbpm/cmd/AsyncProcessSignal.java	2009-06-24 11:37:01 UTC (rev 27114)
@@ -158,25 +158,29 @@
             logger.debug("Sent signal task to message service for token id " + tokenId + " from process instance " + processInstanceId) ;
         }
         
-        final TransactionStrategy transactionStrategy = TransactionStrategy.getTransactionStrategy(true) ;
-        try
+        final JobExecutor jobExecutor = jbpmContext.getJbpmConfiguration().getJobExecutor() ;
+        if (jobExecutor != null)
         {
-            if (transactionStrategy.isActive())
+            final TransactionStrategy transactionStrategy = TransactionStrategy.getTransactionStrategy(true) ;
+            try
             {
-                final Transaction transaction = (Transaction)transactionStrategy.getTransaction() ;
-                if ((transaction != null) && !SYNCHRONISATIONS.containsKey(transaction))
+                if (transactionStrategy.isActive())
                 {
-                    final Synchronization synch = new JobNotifierSynchronisation(transaction, jbpmContext.getJbpmConfiguration().getJobExecutor()) ;
-                    transaction.registerSynchronization(synch) ;
-                    SYNCHRONISATIONS.put(transaction, synch) ;
+                    final Transaction transaction = (Transaction)transactionStrategy.getTransaction() ;
+                    if ((transaction != null) && !SYNCHRONISATIONS.containsKey(transaction))
+                    {
+                        final Synchronization synch = new JobNotifierSynchronisation(transaction, jobExecutor) ;
+                        transaction.registerSynchronization(synch) ;
+                        SYNCHRONISATIONS.put(transaction, synch) ;
+                    }
                 }
             }
-        }
-        catch (final Exception ex)
-        {
-            if (logger.isDebugEnabled())
+            catch (final Exception ex)
             {
-                logger.debug("Failed to register synchronization", ex) ;
+                if (logger.isDebugEnabled())
+                {
+                    logger.debug("Failed to register synchronization", ex) ;
+                }
             }
         }
     }