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

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

Author: estebanschifman
Date: 2006-11-03 15:40:01 -0500 (Fri, 03 Nov 2006)
New Revision: 7384

Modified:
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/CbrJmsQueueListener.java
Log:
Respond to invoker adding serviceName list to Message

Modified: labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/CbrJmsQueueListener.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/CbrJmsQueueListener.java	2006-11-03 20:33:35 UTC (rev 7383)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/CbrJmsQueueListener.java	2006-11-03 20:40:01 UTC (rev 7384)
@@ -22,11 +22,15 @@
 
 package org.jboss.soa.esb.listeners.message;
 
+import java.net.URISyntaxException;
 import java.util.Collection;
 
 import org.apache.log4j.Logger;
 import org.apache.log4j.Priority;
 import org.jboss.soa.esb.ConfigurationException;
+import org.jboss.soa.esb.addressing.EPR;
+import org.jboss.soa.esb.couriers.CourierException;
+import org.jboss.soa.esb.couriers.CourierFactory;
 import org.jboss.soa.esb.helpers.ConfigTree;
 import org.jboss.soa.esb.listeners.ListenerTagNames;
 import org.jboss.soa.esb.message.Message;
@@ -86,6 +90,20 @@
 	        			if (Boolean.FALSE.equals(message.getProperties().getProperty(MessageRouter.DELIVER_MESSAGES))) {
 	        				//CallBack to the action processor.
 	        			}
+	        			message.getBody().add(MessageRouter.ROUTING_DESTINATION_SERVICE_LIST, destinationServices);
+	        			try 
+	        			{ 
+	        				EPR reply = message.getHeader().getCall().getReplyTo();
+	        				CourierFactory.getCourier(reply).deliver(message);
+	        			}
+	        			catch (URISyntaxException e)
+	        			{
+	        				
+	        			}
+	        			catch (CourierException e)
+	        			{
+	        				
+	        			}
 	        		} else {
 	        			//TODO allow for getting the ruleSet from the message and not from the configuration
 	        			//String messageRuleSet = message.getRuleSet();