[jboss-svn-commits] JBL Code SVN: r8970 - labs/jbossesb/trunk/product/samples/trailblazer/esb/src/org/jboss/soa/esb/samples/trailblazer/actions.

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

Author: daniel.brum at jboss.com
Date: 2007-01-22 12:57:06 -0500 (Mon, 22 Jan 2007)
New Revision: 8970

Modified:
   labs/jbossesb/trunk/product/samples/trailblazer/esb/src/org/jboss/soa/esb/samples/trailblazer/actions/CreditAgencyActions.java
Log:
2Way courier used for CreditAgency interaction


Modified: labs/jbossesb/trunk/product/samples/trailblazer/esb/src/org/jboss/soa/esb/samples/trailblazer/actions/CreditAgencyActions.java
===================================================================
--- labs/jbossesb/trunk/product/samples/trailblazer/esb/src/org/jboss/soa/esb/samples/trailblazer/actions/CreditAgencyActions.java	2007-01-22 17:54:26 UTC (rev 8969)
+++ labs/jbossesb/trunk/product/samples/trailblazer/esb/src/org/jboss/soa/esb/samples/trailblazer/actions/CreditAgencyActions.java	2007-01-22 17:57:06 UTC (rev 8970)
@@ -21,9 +21,15 @@
  * @daniel.brum at jboss.com
  */
 
+import java.util.Random;
+
 import org.apache.log4j.Logger;
+import org.jboss.soa.esb.addressing.EPR;
+import org.jboss.soa.esb.couriers.CourierFactory;
 import org.jboss.soa.esb.helpers.ConfigTree;
 import org.jboss.soa.esb.message.Message;
+import org.jboss.soa.esb.message.format.MessageFactory;
+import org.jboss.soa.esb.message.format.MessageType;
 import org.jboss.soa.esb.util.Util;
 
 public class CreditAgencyActions {
@@ -39,20 +45,26 @@
 	public Message processCreditRequest(Message message) throws Exception{
 		
 		_message = message;
-//		Message replyMessage=null;
+		Message replyMessage=null;
 		
 		_logger.debug("message received: " + Util.serialize(message) );		
 		
-		//TODO: do smooks transformation on the CSV received
 		String csvData = new String(message.getBody().getContents());
 		_logger.debug("csv data received: " + csvData);
 		
-		//TODO: return a score
-//		replyMessage = MessageFactory.getInstance().getMessage(MessageType.JBOSS_XML);
-//		replyMessage.getBody().setContents("TEST REPLY".getBytes());
-//		EPR replyEPR = message.getHeader().getCall().getReplyTo();
-//		CourierFactory.getCourier(replyEPR).deliver(message);       
 		
+		//generate a random score between 1 and 10
+		Random rand = new Random();
+		int n = 10;
+		int score = rand.nextInt(n+1);
+		
+		//send back the reply
+		replyMessage = MessageFactory.getInstance().getMessage(MessageType.JBOSS_XML);
+		replyMessage.getBody().setContents(Integer.toString(score).getBytes());
+		EPR replyEPR = message.getHeader().getCall().getReplyTo();
+		CourierFactory.getCourier(replyEPR).deliver(message);       
+		
+		//send the message back to the action processing chain
 		return message;
 	}
 	
@@ -60,13 +72,9 @@
 		
 		_message = message;
 		_logger.debug("message received in processCreditRequest with message: " + Util.serialize(message));
-//		ActionUtils.getTaskObject(message);
-//		System.out.println("CreditAgencyActions.debugMessage(): in the action chain message: " + Util.serialize(message));
+
 		
-//		JMSEpr replyTo = new JMSEpr(message.getHeader().getCall().getReplyTo());
-//		CourierFactory.getCourier(replyTo).deliver(message);
 		
-		
 		return message;
 	}