[jboss-svn-commits] JBL Code SVN: r7569 - labs/jbossesb/trunk/product/samples/trailblazer2/client/src/org/jboss/soa/esb/samples/trailblazer/web

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

Author: daniel.brum at jboss.com
Date: 2006-11-13 13:09:38 -0500 (Mon, 13 Nov 2006)
New Revision: 7569

Modified:
   labs/jbossesb/trunk/product/samples/trailblazer2/client/src/org/jboss/soa/esb/samples/trailblazer/web/LoanBrokerWS.java
Log:


Modified: labs/jbossesb/trunk/product/samples/trailblazer2/client/src/org/jboss/soa/esb/samples/trailblazer/web/LoanBrokerWS.java
===================================================================
--- labs/jbossesb/trunk/product/samples/trailblazer2/client/src/org/jboss/soa/esb/samples/trailblazer/web/LoanBrokerWS.java	2006-11-13 17:52:55 UTC (rev 7568)
+++ labs/jbossesb/trunk/product/samples/trailblazer2/client/src/org/jboss/soa/esb/samples/trailblazer/web/LoanBrokerWS.java	2006-11-13 18:09:38 UTC (rev 7569)
@@ -36,8 +36,8 @@
 import org.jboss.soa.esb.addressing.eprs.JMSEpr;
 import org.jboss.soa.esb.couriers.Courier;
 import org.jboss.soa.esb.couriers.CourierFactory;
+import org.jboss.soa.esb.couriers.CourierUtil;
 import org.jboss.soa.esb.helpers.ConfigTree;
-import org.jboss.soa.esb.listeners.message.JmsQueueReplyListener;
 import org.jboss.soa.esb.message.Message;
 import org.jboss.soa.esb.message.format.MessageFactory;
 import org.jboss.soa.esb.message.format.MessageType;
@@ -95,21 +95,10 @@
 				Courier courier = CourierFactory.getCourier(epr);
 				//If not successful try the next EPR
 				if (JMSEpr.class.equals(epr.getClass())) {					
-						//create a reply-to EPR
-						JmsQueueReplyListener jmsQueueReplyListener = new JmsQueueReplyListener();
-						JMSEpr jpr = (JMSEpr)epr;
-						JMSEpr replyEpr = null;
-						replyEpr = 
-							new JMSEpr(jpr.getDestinationType()
-									,jpr.getDestinationName()
-									,jpr.getConnectionFactory()
-									,jpr.getJndiType()
-									,jpr.getJndiURL()
-									,jmsQueueReplyListener.getReplySelector()
-									);
-						message.getHeader().getCall().setReplyTo(replyEpr);						
+					//create a reply-to EPR
+					EPR replyToEpr = CourierUtil.getTemporaryReplyToEpr(epr);						
 						if (courier.deliver(message)) {
-							replyMessage = jmsQueueReplyListener.listen(replyEpr, 5000);
+							replyMessage = courier.pickup(5000);
 							logger.info("reply from service received: " + replyMessage);
 							break;
 					} else {
@@ -150,6 +139,6 @@
 	ConfigTree  config = null;
 	private final String CONFIG_FILE = "trailblazer-properties.xml";
 	private final String SERVICE_NAME = "org.jboss.soa.esb.trailblazer.request.service.epr.name";
-	private final String SERVICE_CAT  = "org.jboss.soa.esb.trailblazer.request.service.category";
+	private final String SERVICE_CAT  = "org.jboss.soa.esb.trailblazer.request.service.category";	
 
 }