[jboss-svn-commits] JBL Code SVN: r7520 - 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:09:03 -0500 (Thu, 09 Nov 2006)
New Revision: 7520

Modified:
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/actions/CbrProxyAction.java
Log:
isolate logic to determine replyToEpr

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 19:54:52 UTC (rev 7519)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/actions/CbrProxyAction.java	2006-11-09 20:09:03 UTC (rev 7520)
@@ -128,10 +128,7 @@
 					if (epr instanceof JMSEpr) {
 						//Setting the replyTo to the queue we specific in the epr we are going to call
 						//The selectors will do the job.
-						JMSEpr jpr = (JMSEpr)epr;
-						JMSEpr replyEpr =  new JMSEpr(jpr.getDestinationType()  ,jpr.getDestinationName()
-							                         ,jpr.getConnectionFactory(),jpr.getJndiType()
-							                         ,jpr.getJndiURL()          ,CourierUtil.getReplySelector());
+						EPR replyEpr =  getReplyToEpr(epr);
 						if (message.getHeader().getCall()==null) {
 							Call call = new Call();
 							message.getHeader().setCall(call);
@@ -165,6 +162,14 @@
     	}
         return replyMessage;
     }
+    
+    private EPR getReplyToEpr(EPR epr) throws URISyntaxException
+    {
+    	JMSEpr jpr = (JMSEpr) epr;
+    	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