[jboss-svn-commits] JBL Code SVN: r5705 - labs/jbossesb/trunk/product/docs/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
Thu Aug 10 10:55:47 EDT 2006
Author: daniel.brum at jboss.com
Date: 2006-08-10 10:55:45 -0400 (Thu, 10 Aug 2006)
New Revision: 5705
Modified:
labs/jbossesb/trunk/product/docs/samples/trailblazer/bankloanbrokerdemo/java/src/org/jboss/soa/esb/samples/loanbroker/actions/ProcessBanksFileResponse.java
labs/jbossesb/trunk/product/docs/samples/trailblazer/bankloanbrokerdemo/java/src/org/jboss/soa/esb/samples/loanbroker/actions/ProcessBanksJMSResponse.java
labs/jbossesb/trunk/product/docs/samples/trailblazer/bankloanbrokerdemo/java/src/org/jboss/soa/esb/samples/loanbroker/actions/ProcessCreditResponse.java
Log:
Modified: labs/jbossesb/trunk/product/docs/samples/trailblazer/bankloanbrokerdemo/java/src/org/jboss/soa/esb/samples/loanbroker/actions/ProcessBanksFileResponse.java
===================================================================
--- labs/jbossesb/trunk/product/docs/samples/trailblazer/bankloanbrokerdemo/java/src/org/jboss/soa/esb/samples/loanbroker/actions/ProcessBanksFileResponse.java 2006-08-10 14:46:56 UTC (rev 5704)
+++ labs/jbossesb/trunk/product/docs/samples/trailblazer/bankloanbrokerdemo/java/src/org/jboss/soa/esb/samples/loanbroker/actions/ProcessBanksFileResponse.java 2006-08-10 14:55:45 UTC (rev 5705)
@@ -57,6 +57,7 @@
SystemProperties.getJndiServerURL());
Customer customer = (Customer) esbHandler.getObject(org.jboss.soa.esb.samples.loanbroker.domain.Customer.class, uid);
+ m_oLogger.info(this.getClass().getSimpleName() + " -- Business Object BEFORE Loan Offer is added: " + customer.toDTO().toXml());
// now update this Customer with a LoanOffer based on the response from the Bank
LoanOffer offer = new LoanOffer((String)null);
offer.setField(LoanOffer.ATTRIB.interestRate, messagePart[0]);
@@ -66,7 +67,7 @@
// System.out.println(customer.);
customer.addOffer(offer);
esbHandler.rplObject(customer); //update the object store
- m_oLogger.info("Business Object AFTER File Offers Update: " + customer.toDTO().toXml());
+ m_oLogger.info(this.getClass().getSimpleName() + " -- Business Object BEFORE Loan Offer is added: " + customer.toDTO().toXml());
}
Modified: labs/jbossesb/trunk/product/docs/samples/trailblazer/bankloanbrokerdemo/java/src/org/jboss/soa/esb/samples/loanbroker/actions/ProcessBanksJMSResponse.java
===================================================================
--- labs/jbossesb/trunk/product/docs/samples/trailblazer/bankloanbrokerdemo/java/src/org/jboss/soa/esb/samples/loanbroker/actions/ProcessBanksJMSResponse.java 2006-08-10 14:46:56 UTC (rev 5704)
+++ labs/jbossesb/trunk/product/docs/samples/trailblazer/bankloanbrokerdemo/java/src/org/jboss/soa/esb/samples/loanbroker/actions/ProcessBanksJMSResponse.java 2006-08-10 14:55:45 UTC (rev 5705)
@@ -39,17 +39,17 @@
SystemProperties.getJndiServerURL());
Customer customer = (Customer) esbHandler.getObject(org.jboss.soa.esb.samples.loanbroker.domain.Customer.class, bankResponse.customerUID);
+ m_oLogger.info(this.getClass().getSimpleName() + " -- Business Object BEFORE Loan Offer is added: " + customer.toDTO().toXml());
//now update this Customer with a LoanOffer based on the response from the Bank
LoanOffer offer = new LoanOffer((String)null);
offer.setField(LoanOffer.ATTRIB.interestRate, (bankResponse.interestRate).toString());
offer.setField(LoanOffer.ATTRIB.quoteId, bankResponse.quoteId);
offer.setField(LoanOffer.ATTRIB.errorCode, Integer.toString(bankResponse.errorCode));
-// System.out.println("CUSTOMER JUST BEFORE OFFER IS ADDED");
-// System.out.println(customer.);
+//
customer.addOffer(offer);
esbHandler.rplObject(customer); //update the object store
- m_oLogger.info("Business Object AFTER JMS Offers Update: " + customer.toDTO().toXml());
+ m_oLogger.info(this.getClass().getSimpleName() + " -- Business Object AFTER Loan Offer is added: " + customer.toDTO().toXml());
//TODO: add logic to send an email to customer once MAX_OFFERS has been reached
Modified: labs/jbossesb/trunk/product/docs/samples/trailblazer/bankloanbrokerdemo/java/src/org/jboss/soa/esb/samples/loanbroker/actions/ProcessCreditResponse.java
===================================================================
--- labs/jbossesb/trunk/product/docs/samples/trailblazer/bankloanbrokerdemo/java/src/org/jboss/soa/esb/samples/loanbroker/actions/ProcessCreditResponse.java 2006-08-10 14:46:56 UTC (rev 5704)
+++ labs/jbossesb/trunk/product/docs/samples/trailblazer/bankloanbrokerdemo/java/src/org/jboss/soa/esb/samples/loanbroker/actions/ProcessCreditResponse.java 2006-08-10 14:55:45 UTC (rev 5705)
@@ -46,7 +46,9 @@
import com.thoughtworks.xstream.XStream;
-public class ProcessCreditResponse extends AbstractAction {
+public class ProcessCreditResponse extends AbstractAction {
+
+ IpersistHandler esbHandler;
public ProcessCreditResponse(DomElement p_oP, Object p_oCurr) throws Exception {
super(p_oP, p_oCurr);
@@ -63,24 +65,23 @@
//get the credit response information and send to banks
String[] msg = (String[])((ObjectMessage)m_oCurr).getObject();
- CreditCheckResponseNotification response = CreditCheckResponseNotification.fromArray(msg);
-// System.out.println(response.toString());
+ CreditCheckResponseNotification response = CreditCheckResponseNotification.fromArray(msg);
// get handle to the JBossESB Event object store
- IpersistHandler esbHandler = PersistHandlerFactory.getPersistHandler("remote",
+ esbHandler = PersistHandlerFactory.getPersistHandler("remote",
SystemProperties.getJndiServerType(),
SystemProperties.getJndiServerURL());
Customer customer = (Customer) esbHandler.getObject(org.jboss.soa.esb.samples.loanbroker.domain.Customer.class, response.customerUID);
- m_oLogger.info("BusinessObject BEFORE credit request: " + customer.toDTO().toXml());
+ m_oLogger.info(this.getClass().getSimpleName() + " -- Business Object BEFORE Credit Rating is added: " + customer.toDTO().toXml());
CreditRating rating = new CreditRating((String)null);
rating.setScore(response.score);
customer.setRating(rating);
esbHandler.rplObject(customer); //update the object store
- m_oLogger.info("BusinessObject AFTER credit update: " + customer.toDTO().toXml());
+ m_oLogger.info(this.getClass().getSimpleName() + " -- Business Object AFTER Credit Rating is added: " + customer.toDTO().toXml());
- sendJMSToBank(customer);
- sendFileToBank(customer);
+ sendJMSToBank(response.customerUID);
+ sendFileToBank(response.customerUID);
} //________________________________
@@ -112,8 +113,9 @@
}
} //________________________________
- private void sendJMSToBank(Customer customer) {
+ private void sendJMSToBank(long customerUID) throws Exception{
try {
+ Customer customer = (Customer) esbHandler.getObject(org.jboss.soa.esb.samples.loanbroker.domain.Customer.class, customerUID);
Context ctx = AppServerContext.getServerContext(LoanBrokerConstants.JNDI_TYPE, LoanBrokerConstants.JNDI_URL);
Queue queue = (Queue) ctx.lookup(LoanBrokerConstants.BANK_JMS_REQUEST_QUEUE);
QueueConnectionFactory factory = (QueueConnectionFactory) ctx.lookup("ConnectionFactory");
@@ -139,7 +141,8 @@
}
- private void sendFileToBank(Customer customer) {
+ private void sendFileToBank(long customerUID) throws Exception{
+ Customer customer = (Customer) esbHandler.getObject(org.jboss.soa.esb.samples.loanbroker.domain.Customer.class, customerUID);
File writableDir=null;
//check to see if we can write to destination first
File tmpDir = new File(LoanBrokerConstants.BANK_REQUEST_DIR);
More information about the jboss-svn-commits
mailing list