[jboss-svn-commits] JBL Code SVN: r14838 - labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/notification/jms.

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

Author: kevin.conner at jboss.com
Date: 2007-09-03 13:18:01 -0400 (Mon, 03 Sep 2007)
New Revision: 14838

Modified:
   labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/notification/jms/DefaultJMSPropertiesSetter.java
Log:
Restrict JMSX properties to client ones: JBESB-974

Modified: labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/notification/jms/DefaultJMSPropertiesSetter.java
===================================================================
--- labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/notification/jms/DefaultJMSPropertiesSetter.java	2007-09-03 16:05:04 UTC (rev 14837)
+++ labs/jbossesb/trunk/product/rosetta/src/org/jboss/soa/esb/notification/jms/DefaultJMSPropertiesSetter.java	2007-09-03 17:18:01 UTC (rev 14838)
@@ -47,6 +47,14 @@
 {
 	private Logger log = Logger.getLogger( DefaultJMSPropertiesSetter.class );
 	
+        /**
+         * Client JMSX Group ID.
+         */
+        private static final String JMSX_GROUP_ID = "JMSXGroupID" ;
+        /**
+         * Client JMSX Group Seq.
+         */
+        private static final String JMSX_GROUP_SEQ = "JMSXGroupSeq" ;
 	/**
      * Set JMS Header fields on the outgoing JMS Message.
      * </p>
@@ -114,6 +122,13 @@
 			if ( !Strings.isValidJavaIdentifier( key ))
 				continue;
 			
+                        if (key.startsWith("JMSX"))
+                        {
+                            if (!JMSX_GROUP_ID.equals(key) && !JMSX_GROUP_SEQ.equals(key))
+                            {
+                                continue ;
+                            }
+                        }
 			Object value = properties.getProperty( key );
 			log.debug( "Setting outgoing JMSProperty, key : " + key + ", value : " + value );
 			if ( value instanceof String  )