[jbpm-commits] JBoss JBPM SVN: r6710 - jbpm3/branches/jbpm-3.2-soa/enterprise-jee5/src/main/java/org/jbpm/jms.

[do-not-reply at jboss.org]

Author: bradsdavis
Date: 2010-09-30 09:45:49 -0400 (Thu, 30 Sep 2010)
New Revision: 6710

Modified:
   jbpm3/branches/jbpm-3.2-soa/enterprise-jee5/src/main/java/org/jbpm/jms/JmsConnectorService.java
Log:
Added the ability to exclusively process for a given process instance.  This uses the JMS Group ID to ensure 1 MDB consumer at a time.

Modified: jbpm3/branches/jbpm-3.2-soa/enterprise-jee5/src/main/java/org/jbpm/jms/JmsConnectorService.java
===================================================================
--- jbpm3/branches/jbpm-3.2-soa/enterprise-jee5/src/main/java/org/jbpm/jms/JmsConnectorService.java	2010-09-30 13:44:55 UTC (rev 6709)
+++ jbpm3/branches/jbpm-3.2-soa/enterprise-jee5/src/main/java/org/jbpm/jms/JmsConnectorService.java	2010-09-30 13:45:49 UTC (rev 6710)
@@ -106,6 +106,14 @@
       //higher priority for timers.
       message.setJMSPriority(9);
     }
+    
+    if(!(job instanceof Timer))
+    {
+    	if(job.isExclusive())
+    	{
+    		message.setStringProperty("JMSXGroupID", "GROUP:"+job.getProcessInstance().getId());
+    	}
+    }
   }
 
   public void createTimer(Timer timer) {