[overlord-commits] Overlord SVN: r438 - cdl/trunk/samples/jbossesb/trailblazer/client/java-files.

Author: jeff.yuchang Date: 2008-11-12 13:16:01 -0500 (Wed, 12 Nov 2008) New Revision: 438 Added: cdl/trunk/samples/jbossesb/trailblazer/client/java-files/FailedLoanBroker.java cdl/trunk/samples/jbossesb/trailblazer/client/java-files/SuccessfulLoanBroker.java Log: * Forgot to add these two files in last commit. Added: cdl/trunk/samples/jbossesb/trailblazer/client/java-files/FailedLoanBroker.java =================================================================== --- cdl/trunk/samples/jbossesb/trailblazer/client/java-files/FailedLoanBroker.java (rev 0) +++ cdl/trunk/samples/jbossesb/trailblazer/client/java-files/FailedLoanBroker.java 2008-11-12 18:16:01 UTC (rev 438) @@ -0,0 +1,228 @@ +package org.jboss.soa.esb.samples.trailblazer.loanbroker; + +/* + * JBoss, Home of Professional Open Source + * Copyright 2006, JBoss Inc., and others contributors as indicated + * by the @authors tag. All rights reserved. + * See the copyright.txt in the distribution for a + * full listing of individual contributors. + * This copyrighted material is made available to anyone wishing to use, + * modify, copy, or redistribute it subject to the terms and conditions + * of the GNU Lesser General Public License, v. 2.1. + * This program is distributed in the hope that it will be useful, but WITHOUT A + * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A + * PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details. + * You should have received a copy of the GNU Lesser General Public License, + * v.2.1 along with this distribution; if not, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, + * MA 02110-1301, USA. + * + * (C) 2005-2006, + * @author mark.little(a)jboss.com + */ + + +import java.util.Properties; + +import javax.xml.parsers.DocumentBuilder; +import javax.xml.parsers.DocumentBuilderFactory; + +import org.apache.log4j.Logger; +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.samples.trailblazer.util.TrailblazerProperties; +import org.jboss.soa.esb.samples.trailblazer.web.WebCustomer; +import org.jboss.soa.esb.client.ServiceInvoker; + +/* + * LoanBroker is responsible for getting customer requests for loans onto the JBoss ESB + * Requests will come from a JSR-181 pojo web service (@org.jboss.soa.esb.samples.trailblazer.web.LoanBrokerWS) + * The sequence of events from the LoanBroker are: + * 1 - Prepare a request for the CreditAgency (transform the customer into a XML representation) + * 2 - Send to CreditAgency and get response (lookup the customer using the SSN (see @CustomerMasterFile) + * 3 - Prepare a LoanRequest for each of the banks in their unique data structures and send + * 4 - Collect the response(s) from the bank(s) and send an email to the customer with the quote offers + */ + +public class LoanBroker { + + private static Logger logger = Logger.getLogger(LoanBroker.class); + //used to locate our entries in the trailblazer-properties + private final String CREDIT_AGENCY_SERVICE_NAME = "creditagency.service.epr.name"; + private final String CREDIT_AGENCY_SERVICE_CAT = "creditagency.service.category"; + private final String BANK1_SERVICE_NAME = "bank1.service.epr.name"; + private final String BANK1_SERVICE_CAT = "bank1.service.category"; + private final String BANK2_SERVICE_NAME = "bank2.service.epr.name"; + private final String BANK2_SERVICE_CAT = "bank2.service.category"; + private final String NOTIFIER_SERVICE_NAME = "notifier.service.epr.name"; + private final String NOTIFIER_SERVICE_CAT = "notifier.service.category"; + private Properties properties = new TrailblazerProperties(); + private ServiceInvoker serviceInvoker; + private ServiceInvoker bank1Invoker; + private ServiceInvoker bank2Invoker; + private ServiceInvoker notifierInvoker; + + public LoanBroker() { + String serviceCategoryName = properties.getProperty(CREDIT_AGENCY_SERVICE_CAT); + String serviceName = properties.getProperty(CREDIT_AGENCY_SERVICE_NAME); + String bank1ServiceCategoryName = properties.getProperty(BANK1_SERVICE_CAT); + String bank1ServiceName = properties.getProperty(BANK1_SERVICE_NAME); + String bank2ServiceCategoryName = properties.getProperty(BANK2_SERVICE_CAT); + String bank2ServiceName = properties.getProperty(BANK2_SERVICE_NAME); + String notifierServiceCategoryName = properties.getProperty(NOTIFIER_SERVICE_CAT); + String notifierServiceName = properties.getProperty(NOTIFIER_SERVICE_NAME); + + try { + serviceInvoker = new ServiceInvoker(serviceCategoryName, serviceName); + } catch (Exception e) { + throw new RuntimeException("Failed to create ServiceInvoker for '" + serviceCategoryName + ":" + serviceName + "'.", e); + } + + try { + bank1Invoker = new ServiceInvoker(bank1ServiceCategoryName, bank1ServiceName); + } catch (Exception e) { + throw new RuntimeException("Failed to create ServiceInvoker for '" + bank1ServiceCategoryName + ":" + bank1ServiceName + "'.", e); + } + + try { + bank2Invoker = new ServiceInvoker(bank2ServiceCategoryName, bank2ServiceName); + } catch (Exception e) { + throw new RuntimeException("Failed to create ServiceInvoker for '" + bank2ServiceCategoryName + ":" + bank2ServiceName + "'.", e); + } + + try { + notifierInvoker = new ServiceInvoker(notifierServiceCategoryName, notifierServiceName); + } catch (Exception e) { + throw new RuntimeException("Failed to create ServiceInvoker for '" + notifierServiceCategoryName + ":" + notifierServiceName + "'.", e); + } + } + + public void processLoanRequest(WebCustomer wCustomer) { + + Customer customer = getCustomer(wCustomer); + //keep the customer in a file someplace for later use, if needed + CustomerMasterFile.addCustomer(String.valueOf(customer.ssn), customer); + + //step 1 - send to credit agency for credit score if available + + int score=sendToCreditAgency(customer); + + //added a pause here to give the creditagency some time to reply + try { + Thread.sleep(5000); + } catch (InterruptedException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + + //step 2 - check if score is acceptable + + if (score >= 7) { + //step 3a - send to Bank - async + System.out.println("sending to first Bank..."); + sendToBank(bank1Invoker, customer, "b1"); + + System.out.println("sending to second Bank..."); + sendToBank(bank2Invoker, customer, "b2"); + } else { + //step 3b - notify customer that credit is not acceptable + String invalidCredit="<insufficientCredit><customerUID>"+customer.ssn+"</customerUID>" + + "<ref>0</ref>"+ + "<customerEmail>"+customer.email+"</customerEmail>" + + "<errorCode>3</errorCode></insufficientCredit>"; + + Message notifyMessage = MessageFactory.getInstance().getMessage(MessageType.JBOSS_XML); + notifyMessage.getBody().add(invalidCredit); + + try { + notifierInvoker.deliverAsync(notifyMessage); + } catch (Exception e) { + logger.error(e); + } + } + } + + private Customer getCustomer(WebCustomer wCustomer) { + Customer customer = new Customer(); + customer.ssn = wCustomer.getSsn(); + customer.name = wCustomer.getName(); + customer.address = wCustomer.getAddress(); + customer.email = wCustomer.getEmail(); + customer.salary = wCustomer.getSalary(); + customer.loanAmount = wCustomer.getLoanAmount(); + customer.loanDuration = wCustomer.getLoanDuration(); + customer.creditScore = 0; + + return customer; + } + + + private void sendToBank(ServiceInvoker invoker, Customer customer, String ref) { + Message message = MessageFactory.getInstance().getMessage(MessageType.JBOSS_XML); + + try { + //create a Quote Request that the bank expects + QuoteRequest quote = new QuoteRequest(); + quote.ssn = customer.ssn; + quote.ref = ref; + quote.amount = (int) customer.loanAmount; + quote.creditScore = customer.creditScore; + quote.creditHistoryLen = 0; //not sure who added this one + quote.term = customer.loanDuration; + quote.customerEmail = customer.email; + + message.getBody().add(quote.getXML()); + invoker.deliverAsync(message); + + } catch (Exception e) { + logger.error(e); + } + } + + private int sendToCreditAgency(Customer customer) { + Message message = MessageFactory.getInstance().getMessage(MessageType.JBOSS_XML); + Message replyMessage; + int score = 0; + + try { + logger.debug("sending to credit agency"); + + //set the customer details inside the message + message.getBody().add(customer.getXML()); + + logger.info("Sending request to creditAgency: " + message.getBody().get()); + + replyMessage = serviceInvoker.deliverSync(message, 5000); + if (replyMessage != null) { + logger.info("received reply from creditAgency action: " + replyMessage.getBody().get()); + + String xml =(String)replyMessage.getBody().get(); + + DocumentBuilderFactory fact=DocumentBuilderFactory.newInstance(); + fact.setNamespaceAware(true); + + java.io.InputStream xmlstr= + new java.io.ByteArrayInputStream(xml.getBytes()); + + DocumentBuilder builder=fact.newDocumentBuilder(); + org.w3c.dom.Document doc=builder.parse(xmlstr); + + org.w3c.dom.Element tree = doc.getDocumentElement(); + + score = Integer.parseInt(tree.getAttribute("score")); + + logger.debug("Score from XML is: "+score); + } else { + logger.debug("reply not received from credit agency - setting a value of 5"); + score = 5; + } + } catch (Exception ex2) { + logger.error("exception occured: " + ex2); + } + + return score; + } + + +} Added: cdl/trunk/samples/jbossesb/trailblazer/client/java-files/SuccessfulLoanBroker.java =================================================================== --- cdl/trunk/samples/jbossesb/trailblazer/client/java-files/SuccessfulLoanBroker.java (rev 0) +++ cdl/trunk/samples/jbossesb/trailblazer/client/java-files/SuccessfulLoanBroker.java 2008-11-12 18:16:01 UTC (rev 438) @@ -0,0 +1,228 @@ +package org.jboss.soa.esb.samples.trailblazer.loanbroker; + +/* + * JBoss, Home of Professional Open Source + * Copyright 2006, JBoss Inc., and others contributors as indicated + * by the @authors tag. All rights reserved. + * See the copyright.txt in the distribution for a + * full listing of individual contributors. + * This copyrighted material is made available to anyone wishing to use, + * modify, copy, or redistribute it subject to the terms and conditions + * of the GNU Lesser General Public License, v. 2.1. + * This program is distributed in the hope that it will be useful, but WITHOUT A + * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A + * PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details. + * You should have received a copy of the GNU Lesser General Public License, + * v.2.1 along with this distribution; if not, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, + * MA 02110-1301, USA. + * + * (C) 2005-2006, + * @author mark.little(a)jboss.com + */ + + +import java.util.Properties; + +import javax.xml.parsers.DocumentBuilder; +import javax.xml.parsers.DocumentBuilderFactory; + +import org.apache.log4j.Logger; +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.samples.trailblazer.util.TrailblazerProperties; +import org.jboss.soa.esb.samples.trailblazer.web.WebCustomer; +import org.jboss.soa.esb.client.ServiceInvoker; + +/* + * LoanBroker is responsible for getting customer requests for loans onto the JBoss ESB + * Requests will come from a JSR-181 pojo web service (@org.jboss.soa.esb.samples.trailblazer.web.LoanBrokerWS) + * The sequence of events from the LoanBroker are: + * 1 - Prepare a request for the CreditAgency (transform the customer into a XML representation) + * 2 - Send to CreditAgency and get response (lookup the customer using the SSN (see @CustomerMasterFile) + * 3 - Prepare a LoanRequest for each of the banks in their unique data structures and send + * 4 - Collect the response(s) from the bank(s) and send an email to the customer with the quote offers + */ + +public class LoanBroker { + + private static Logger logger = Logger.getLogger(LoanBroker.class); + //used to locate our entries in the trailblazer-properties + private final String CREDIT_AGENCY_SERVICE_NAME = "creditagency.service.epr.name"; + private final String CREDIT_AGENCY_SERVICE_CAT = "creditagency.service.category"; + private final String BANK1_SERVICE_NAME = "bank1.service.epr.name"; + private final String BANK1_SERVICE_CAT = "bank1.service.category"; + private final String BANK2_SERVICE_NAME = "bank2.service.epr.name"; + private final String BANK2_SERVICE_CAT = "bank2.service.category"; + private final String NOTIFIER_SERVICE_NAME = "notifier.service.epr.name"; + private final String NOTIFIER_SERVICE_CAT = "notifier.service.category"; + private Properties properties = new TrailblazerProperties(); + private ServiceInvoker serviceInvoker; + private ServiceInvoker bank1Invoker; + private ServiceInvoker bank2Invoker; + private ServiceInvoker notifierInvoker; + + public LoanBroker() { + String serviceCategoryName = properties.getProperty(CREDIT_AGENCY_SERVICE_CAT); + String serviceName = properties.getProperty(CREDIT_AGENCY_SERVICE_NAME); + String bank1ServiceCategoryName = properties.getProperty(BANK1_SERVICE_CAT); + String bank1ServiceName = properties.getProperty(BANK1_SERVICE_NAME); + String bank2ServiceCategoryName = properties.getProperty(BANK2_SERVICE_CAT); + String bank2ServiceName = properties.getProperty(BANK2_SERVICE_NAME); + String notifierServiceCategoryName = properties.getProperty(NOTIFIER_SERVICE_CAT); + String notifierServiceName = properties.getProperty(NOTIFIER_SERVICE_NAME); + + try { + serviceInvoker = new ServiceInvoker(serviceCategoryName, serviceName); + } catch (Exception e) { + throw new RuntimeException("Failed to create ServiceInvoker for '" + serviceCategoryName + ":" + serviceName + "'.", e); + } + + try { + bank1Invoker = new ServiceInvoker(bank1ServiceCategoryName, bank1ServiceName); + } catch (Exception e) { + throw new RuntimeException("Failed to create ServiceInvoker for '" + bank1ServiceCategoryName + ":" + bank1ServiceName + "'.", e); + } + + try { + bank2Invoker = new ServiceInvoker(bank2ServiceCategoryName, bank2ServiceName); + } catch (Exception e) { + throw new RuntimeException("Failed to create ServiceInvoker for '" + bank2ServiceCategoryName + ":" + bank2ServiceName + "'.", e); + } + + try { + notifierInvoker = new ServiceInvoker(notifierServiceCategoryName, notifierServiceName); + } catch (Exception e) { + throw new RuntimeException("Failed to create ServiceInvoker for '" + notifierServiceCategoryName + ":" + notifierServiceName + "'.", e); + } + } + + public void processLoanRequest(WebCustomer wCustomer) { + + Customer customer = getCustomer(wCustomer); + //keep the customer in a file someplace for later use, if needed + CustomerMasterFile.addCustomer(String.valueOf(customer.ssn), customer); + + //step 1 - send to credit agency for credit score if available + + int score=sendToCreditAgency(customer); + + //added a pause here to give the creditagency some time to reply + try { + Thread.sleep(5000); + } catch (InterruptedException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + + //step 2 - check if score is acceptable + + if (score >= 4) { + //step 3a - send to Bank - async + System.out.println("sending to first Bank..."); + sendToBank(bank1Invoker, customer, "b1"); + + System.out.println("sending to second Bank..."); + sendToBank(bank2Invoker, customer, "b2"); + } else { + //step 3b - notify customer that credit is not acceptable + String invalidCredit="<insufficientCredit><customerUID>"+customer.ssn+"</customerUID>" + + "<ref>0</ref>"+ + "<customerEmail>"+customer.email+"</customerEmail>" + + "<errorCode>3</errorCode></insufficientCredit>"; + + Message notifyMessage = MessageFactory.getInstance().getMessage(MessageType.JBOSS_XML); + notifyMessage.getBody().add(invalidCredit); + + try { + notifierInvoker.deliverAsync(notifyMessage); + } catch (Exception e) { + logger.error(e); + } + } + } + + private Customer getCustomer(WebCustomer wCustomer) { + Customer customer = new Customer(); + customer.ssn = wCustomer.getSsn(); + customer.name = wCustomer.getName(); + customer.address = wCustomer.getAddress(); + customer.email = wCustomer.getEmail(); + customer.salary = wCustomer.getSalary(); + customer.loanAmount = wCustomer.getLoanAmount(); + customer.loanDuration = wCustomer.getLoanDuration(); + customer.creditScore = 0; + + return customer; + } + + + private void sendToBank(ServiceInvoker invoker, Customer customer, String ref) { + Message message = MessageFactory.getInstance().getMessage(MessageType.JBOSS_XML); + + try { + //create a Quote Request that the bank expects + QuoteRequest quote = new QuoteRequest(); + quote.ssn = customer.ssn; + quote.ref = ref; + quote.amount = (int) customer.loanAmount; + quote.creditScore = customer.creditScore; + quote.creditHistoryLen = 0; //not sure who added this one + quote.term = customer.loanDuration; + quote.customerEmail = customer.email; + + message.getBody().add(quote.getXML()); + invoker.deliverAsync(message); + + } catch (Exception e) { + logger.error(e); + } + } + + private int sendToCreditAgency(Customer customer) { + Message message = MessageFactory.getInstance().getMessage(MessageType.JBOSS_XML); + Message replyMessage; + int score = 0; + + try { + logger.debug("sending to credit agency"); + + //set the customer details inside the message + message.getBody().add(customer.getXML()); + + logger.info("Sending request to creditAgency: " + message.getBody().get()); + + replyMessage = serviceInvoker.deliverSync(message, 5000); + if (replyMessage != null) { + logger.info("received reply from creditAgency action: " + replyMessage.getBody().get()); + + String xml =(String)replyMessage.getBody().get(); + + DocumentBuilderFactory fact=DocumentBuilderFactory.newInstance(); + fact.setNamespaceAware(true); + + java.io.InputStream xmlstr= + new java.io.ByteArrayInputStream(xml.getBytes()); + + DocumentBuilder builder=fact.newDocumentBuilder(); + org.w3c.dom.Document doc=builder.parse(xmlstr); + + org.w3c.dom.Element tree = doc.getDocumentElement(); + + score = Integer.parseInt(tree.getAttribute("score")); + + logger.debug("Score from XML is: "+score); + } else { + logger.debug("reply not received from credit agency - setting a value of 5"); + score = 5; + } + } catch (Exception ex2) { + logger.error("exception occured: " + ex2); + } + + return score; + } + + +}