[jboss-svn-commits] JBL Code SVN: r27619 - labs/jbossesb/trunk/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-07-06 08:11:15 -0400 (Mon, 06 Jul 2009)
New Revision: 27619

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

Modified: labs/jbossesb/trunk/product/services/jbpm/src/main/java/org/jboss/soa/esb/services/jbpm/cmd/AsyncProcessSignal.java
===================================================================
--- labs/jbossesb/trunk/product/services/jbpm/src/main/java/org/jboss/soa/esb/services/jbpm/cmd/AsyncProcessSignal.java	2009-07-06 12:09:43 UTC (rev 27618)
+++ labs/jbossesb/trunk/product/services/jbpm/src/main/java/org/jboss/soa/esb/services/jbpm/cmd/AsyncProcessSignal.java	2009-07-06 12:11:15 UTC (rev 27619)
@@ -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) ;
+                }
             }
         }
     }