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

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

Author: estebanschifman
Date: 2006-11-09 15:19:14 -0500 (Thu, 09 Nov 2006)
New Revision: 7521

Modified:
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/actions/CbrProxyAction.java
Log:
minor change to CbrProxyAction

Modified: labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/actions/CbrProxyAction.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/actions/CbrProxyAction.java	2006-11-09 20:09:03 UTC (rev 7520)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/actions/CbrProxyAction.java	2006-11-09 20:19:14 UTC (rev 7521)
@@ -165,11 +165,27 @@
     
     private EPR getReplyToEpr(EPR epr) throws URISyntaxException
     {
+    	ConfigTree replyArgs = _config.getFirstChild("replyToEpr");
+    	if (null!=replyArgs)
+    	{
+    		String category = replyArgs.getAttribute(ListenerTagNames.SERVICE_CATEGORY_NAME_TAG);
+    		String name =  replyArgs.getAttribute(ListenerTagNames.SERVICE_NAME_TAG);
+    		Collection<EPR> coll = null;
+    		try 
+    		{ 
+    			coll = RegistryFactory.getRegistry().findEPRs(category, name);
+    			if (coll.size()>0)
+    				return coll.iterator().next();
+    		}
+    		catch (RegistryException e) { }
+    	}
+    	
     	JMSEpr jpr = (JMSEpr) epr;
-    	return new JMSEpr(jpr.getDestinationType()  ,jpr.getDestinationName()
-                ,jpr.getConnectionFactory(),jpr.getJndiType()
-                ,jpr.getJndiURL()          ,CourierUtil.getReplySelector());    
+		return new JMSEpr(jpr.getDestinationType()  ,jpr.getDestinationName()
+            ,jpr.getConnectionFactory(),jpr.getJndiType()
+            ,jpr.getJndiURL()          ,CourierUtil.getReplySelector());
     }
+    
     /**
      * Do *not* route, just deliver. Pulls the destinationServices from the message and deliver the message to the destination(s).
      * @param message