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

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

Author: daniel.brum at jboss.com
Date: 2006-11-27 21:14:40 -0500 (Mon, 27 Nov 2006)
New Revision: 7863

Modified:
   labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/actions/CreditAgencyActions.java
Log:


Modified: labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/actions/CreditAgencyActions.java
===================================================================
--- labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/actions/CreditAgencyActions.java	2006-11-28 01:22:28 UTC (rev 7862)
+++ labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/actions/CreditAgencyActions.java	2006-11-28 02:14:40 UTC (rev 7863)
@@ -22,8 +22,12 @@
  */
 
 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 {
@@ -38,14 +42,20 @@
 	
 	public Message processCreditRequest(Message message) throws Exception{
 		
-		_message = message;		
+		_message = message;
+		Message replyMessage=null;
 		
-		_logger.debug("message received in processCreditRequest with message: " + Util.serialize(message));
+		_logger.debug("message received in processCreditRequest with message: " + Util.serialize(message) );		
 		
 		//TODO: do smooks transformation on the CSV received
-		//TODO: set the credit score
+		String csvData = new String(message.getBody().getContents());
+		_logger.debug("csv data received by credit agency: " + 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);       
 		
 		return message;
 	}