[jboss-svn-commits] JBL Code SVN: r8314 - labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway

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

Author: estebanschifman
Date: 2006-12-14 07:16:44 -0500 (Thu, 14 Dec 2006)
New Revision: 8314

Modified:
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/JmsGatewayListener.java
Log:
Include JMS message properties in ESB message for default JMS message composer

Modified: labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/JmsGatewayListener.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/JmsGatewayListener.java	2006-12-14 11:51:15 UTC (rev 8313)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/JmsGatewayListener.java	2006-12-14 12:16:44 UTC (rev 8314)
@@ -27,6 +27,7 @@
 import java.lang.reflect.InvocationTargetException;
 import java.lang.reflect.Method;
 import java.util.Collection;
+import java.util.Enumeration;
 
 import javax.enterprise.deploy.spi.exceptions.ConfigurationException;
 import javax.jms.BytesMessage;
@@ -294,7 +295,8 @@
  */
     private static class PackageJmsMessageContents
     {
-    	public Message process (Object obj) throws Exception
+    	@SuppressWarnings("unchecked")
+		public Message process (Object obj) throws Exception
     	{
     		if (! (obj instanceof javax.jms.Message))
     			throw new Exception ("Object must be instance of javax.jms.Message");
@@ -302,8 +304,18 @@
     		if (null==bytes)
     			return null;
 
+    		javax.jms.Message jmsMsg = (javax.jms.Message)obj;
     		Message message = MessageFactory.getInstance().getMessage();
-    		message.getBody().setContents(getMessageContent((javax.jms.Message)obj));
+    		message.getBody().setContents(getMessageContent(jmsMsg));
+    		Enumeration<String> EE = jmsMsg.getPropertyNames();
+    		if(null!=EE)
+    			while (EE.hasMoreElements())
+    			{
+    				String name = EE.nextElement();
+    				Object value = jmsMsg.getObjectProperty(name);
+    				if (null!=value)
+    					message.getProperties().setProperty(name, value);
+    			}
     		return message;
     	}