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) {