[jboss-svn-commits] JBL Code SVN: r6600 - labs/jbossesb/trunk/product/samples/trailblazer/bankloanbrokerdemo/java/src/org/jboss/soa/esb/samples/loanbroker/actions
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Wed Oct 4 14:28:11 EDT 2006
Author: estebanschifman
Date: 2006-10-04 14:28:08 -0400 (Wed, 04 Oct 2006)
New Revision: 6600
Modified:
labs/jbossesb/trunk/product/samples/trailblazer/bankloanbrokerdemo/java/src/org/jboss/soa/esb/samples/loanbroker/actions/ProcessBanksResponse.java
labs/jbossesb/trunk/product/samples/trailblazer/bankloanbrokerdemo/java/src/org/jboss/soa/esb/samples/loanbroker/actions/ProcessCreditRequest.java
labs/jbossesb/trunk/product/samples/trailblazer/bankloanbrokerdemo/java/src/org/jboss/soa/esb/samples/loanbroker/actions/ProcessCreditResponse.java
labs/jbossesb/trunk/product/samples/trailblazer/bankloanbrokerdemo/java/src/org/jboss/soa/esb/samples/loanbroker/actions/ToBankQuoteResponse.java
Log:
Change signature of ActionProcessor.process(Object) to process(Message)
Modified: labs/jbossesb/trunk/product/samples/trailblazer/bankloanbrokerdemo/java/src/org/jboss/soa/esb/samples/loanbroker/actions/ProcessBanksResponse.java
===================================================================
--- labs/jbossesb/trunk/product/samples/trailblazer/bankloanbrokerdemo/java/src/org/jboss/soa/esb/samples/loanbroker/actions/ProcessBanksResponse.java 2006-10-04 18:07:56 UTC (rev 6599)
+++ labs/jbossesb/trunk/product/samples/trailblazer/bankloanbrokerdemo/java/src/org/jboss/soa/esb/samples/loanbroker/actions/ProcessBanksResponse.java 2006-10-04 18:28:08 UTC (rev 6600)
@@ -34,6 +34,7 @@
import org.jboss.soa.esb.samples.loanbroker.domain.LoanOffer;
import org.jboss.soa.esb.services.PersistHandlerFactory;
import org.jboss.soa.esb.services.PersistManager;
+import org.jboss.soa.esb.message.Message;
public class ProcessBanksResponse implements ActionProcessor {
@@ -42,13 +43,16 @@
/* (non-Javadoc)
* @see org.jboss.soa.esb.actions.ActionProcessor#process(java.lang.Object)
*/
- public Object process(Object message) throws ActionProcessingException {
+ public void process(Message message) throws ActionProcessingException {
BankQuoteResponse bankResponse;
+ Object oCurr = message.getBody().get(ActionProcessor.CURRENT_OBJECT);
try {
- bankResponse = (BankQuoteResponse) message;
+ bankResponse = (BankQuoteResponse) oCurr;
} catch(ClassCastException e) {
- throw new ActionProcessingException("Message must be a " + BankQuoteResponse.class.getName() + ". Is " + message.getClass().getName());
+ throw new ActionProcessingException
+ ("Message must be a "+ BankQuoteResponse.class.getName()
+ + ". Is " + oCurr.getClass().getName());
}
try {
@@ -81,8 +85,6 @@
} catch (Exception e) {
throw new ActionProcessingException("Exception processing quote.", e);
}
-
- return message;
}
/* (non-Javadoc)
Modified: labs/jbossesb/trunk/product/samples/trailblazer/bankloanbrokerdemo/java/src/org/jboss/soa/esb/samples/loanbroker/actions/ProcessCreditRequest.java
===================================================================
--- labs/jbossesb/trunk/product/samples/trailblazer/bankloanbrokerdemo/java/src/org/jboss/soa/esb/samples/loanbroker/actions/ProcessCreditRequest.java 2006-10-04 18:07:56 UTC (rev 6599)
+++ labs/jbossesb/trunk/product/samples/trailblazer/bankloanbrokerdemo/java/src/org/jboss/soa/esb/samples/loanbroker/actions/ProcessCreditRequest.java 2006-10-04 18:28:08 UTC (rev 6600)
@@ -30,6 +30,7 @@
import org.jboss.soa.esb.actions.ActionProcessor;
import org.jboss.soa.esb.samples.loanbroker.creditagency.CreditCheckRequest;
import org.jboss.soa.esb.samples.loanbroker.creditagency.CreditCheckResponseNotification;
+import org.jboss.soa.esb.message.Message;
public class ProcessCreditRequest implements ActionProcessor {
@@ -38,14 +39,16 @@
/* (non-Javadoc)
* @see org.jboss.soa.esb.actions.ActionProcessor#process(java.lang.Object)
*/
- public Object process(Object message) throws ActionProcessingException {
- logger.info("processObject was called with <<" +message.toString()+">>");
+ public void process(Message message) throws ActionProcessingException {
+
+ Object oCurr = message.getBody().get(ActionProcessor.CURRENT_OBJECT);
+ logger.info("processObject was called with <<" +oCurr.toString()+">>");
CreditCheckRequest creditRequest;
try {
- creditRequest = (CreditCheckRequest)message;
+ creditRequest = (CreditCheckRequest)oCurr;
} catch (ClassCastException e) {
- throw new ActionProcessingException("Message must be of type " + CreditCheckRequest.class.getName(), e);
+ throw new ActionProcessingException("Current object in message must be of type " + CreditCheckRequest.class.getName(), e);
}
//use a dummy score between 0 and 10
@@ -53,7 +56,10 @@
Integer creditScore = new Integer(generator.nextInt(10));
//create our Response
- return new CreditCheckResponseNotification(creditRequest.requestID, creditScore, creditRequest.customerID);
+ Object oResult = new CreditCheckResponseNotification(creditRequest.requestID, creditScore, creditRequest.customerID);
+ message.getBody().remove(ActionProcessor.CURRENT_OBJECT);
+ if (null!=oResult)
+ message.getBody().add(ActionProcessor.CURRENT_OBJECT,oResult);
}
/* (non-Javadoc)
Modified: labs/jbossesb/trunk/product/samples/trailblazer/bankloanbrokerdemo/java/src/org/jboss/soa/esb/samples/loanbroker/actions/ProcessCreditResponse.java
===================================================================
--- labs/jbossesb/trunk/product/samples/trailblazer/bankloanbrokerdemo/java/src/org/jboss/soa/esb/samples/loanbroker/actions/ProcessCreditResponse.java 2006-10-04 18:07:56 UTC (rev 6599)
+++ labs/jbossesb/trunk/product/samples/trailblazer/bankloanbrokerdemo/java/src/org/jboss/soa/esb/samples/loanbroker/actions/ProcessCreditResponse.java 2006-10-04 18:28:08 UTC (rev 6600)
@@ -35,6 +35,7 @@
import org.jboss.soa.esb.samples.loanbroker.domain.Customer;
import org.jboss.soa.esb.services.PersistHandlerFactory;
import org.jboss.soa.esb.services.PersistManager;
+import org.jboss.soa.esb.message.Message;
public class ProcessCreditResponse implements ActionProcessor {
@@ -45,12 +46,14 @@
/* (non-Javadoc)
* @see org.jboss.soa.esb.actions.ActionProcessor#process(java.lang.Object)
*/
- public Object process(Object message) throws ActionProcessingException {
- logger.info("processObject was called with <<" + message + ">>");
+ public void process(Message message) throws ActionProcessingException {
+
+ Object oCurr = message.getBody().get(ActionProcessor.CURRENT_OBJECT);
+ logger.info("processObject was called with <<" + oCurr + ">>");
CreditCheckResponseNotification response;
try {
- response = (CreditCheckResponseNotification)message;
+ response = (CreditCheckResponseNotification)oCurr;
} catch(ClassCastException e) {
throw new ActionProcessingException("Message must be a " + CreditCheckResponseNotification.class.getName());
}
@@ -73,7 +76,10 @@
// m_oLogger.info(this.getClass().getSimpleName() + " -- Customer2 TEST DEBUG customer2: \n" + customer2.toDTO().toXml());
QuoteRequest quote = CustomerAdapter.bankQuoteFromCustomer(customer);
- return quote;
+
+ message.getBody().remove(ActionProcessor.CURRENT_OBJECT);
+ if (null!=quote)
+ message.getBody().add(ActionProcessor.CURRENT_OBJECT,quote);
} catch(Exception e) {
throw new ActionProcessingException("Failed to process credit check response.", e);
}
Modified: labs/jbossesb/trunk/product/samples/trailblazer/bankloanbrokerdemo/java/src/org/jboss/soa/esb/samples/loanbroker/actions/ToBankQuoteResponse.java
===================================================================
--- labs/jbossesb/trunk/product/samples/trailblazer/bankloanbrokerdemo/java/src/org/jboss/soa/esb/samples/loanbroker/actions/ToBankQuoteResponse.java 2006-10-04 18:07:56 UTC (rev 6599)
+++ labs/jbossesb/trunk/product/samples/trailblazer/bankloanbrokerdemo/java/src/org/jboss/soa/esb/samples/loanbroker/actions/ToBankQuoteResponse.java 2006-10-04 18:28:08 UTC (rev 6600)
@@ -32,6 +32,7 @@
import org.jboss.soa.esb.helpers.DomElement;
import org.jboss.soa.esb.helpers.KeyValuePair;
import org.jboss.soa.esb.samples.loanbroker.banks.BankQuoteResponse;
+import org.jboss.soa.esb.message.Message;
/**
* To {@link org.jboss.soa.esb.samples.loanbroker.banks.BankQuoteResponse} processor.
@@ -53,17 +54,21 @@
/* (non-Javadoc)
* @see org.jboss.soa.esb.actions.ActionProcessor#process(java.lang.Object)
*/
- public Object process(Object messageIn) throws ActionProcessingException {
+ public void process(Message messageIn) throws ActionProcessingException {
BankQuoteResponse bankResponse;
String message;
+ Object oCurr = messageIn.getBody().get(ActionProcessor.CURRENT_OBJECT);
try {
- message = (String)messageIn;
+ message = (String)oCurr;
} catch(ClassCastException e) {
- throw new ActionProcessingException("Message must be a " + String.class.getName() + ". Is " + messageIn.getClass().getName());
+ throw new ActionProcessingException
+ ("Message must be a " + String.class.getName()
+ + ". Is " + oCurr.getClass().getName());
}
- logger.info("Deserialising [" + message + "] to an instance of " + BankQuoteResponse.class.getName());
+ logger.info("Deserialising [" + message + "] to an instance of "
+ + BankQuoteResponse.class.getName());
if(actionName.equalsIgnoreCase(BANK_QUOTE_RESPONSE_XML_TO_BANK_QUOTE_RESPONSE)) {
bankResponse = fromXML(message);
@@ -73,7 +78,9 @@
throw new ActionProcessingException("Unsupported Transformation: " + actionName);
}
- return bankResponse;
+ messageIn.getBody().remove(ActionProcessor.CURRENT_OBJECT);
+ if (null!=bankResponse)
+ messageIn.getBody().add(ActionProcessor.CURRENT_OBJECT,bankResponse);
}
private BankQuoteResponse fromXML(String message) throws ActionProcessingException {
More information about the jboss-svn-commits
mailing list