Author: jeff.yuchang Date: 2009-08-18 02:09:57 -0400 (Tue, 18 Aug 2009) New Revision: 753 Modified: cdl/trunk/samples/jbossesb/client/src/com/acme/services/buyer/WSBuyerClient.java cdl/trunk/samples/jbossesb/common/creditAgency/src/main/java/org/jboss/overlord/examples/creditAgency/CreditAgencyDecision.java cdl/trunk/samples/jbossesb/common/creditAgency/src/main/java/org/jboss/overlord/examples/creditAgency/SetCreditCheckInvalidMessageAction.java cdl/trunk/samples/jbossesb/common/creditAgency/src/main/java/org/jboss/overlord/examples/creditAgency/SetCreditCheckResponseMessageAction.java cdl/trunk/samples/jbossesb/common/creditAgency/src/main/java/org/jboss/overlord/examples/wsdl/CreditAgencyService.java cdl/trunk/samples/jbossesb/common/creditAgency/src/main/resources/META-INF/jboss-esb.xml Log: * finished the ws proxy. Modified: cdl/trunk/samples/jbossesb/client/src/com/acme/services/buyer/WSBuyerClient.java =================================================================== --- cdl/trunk/samples/jbossesb/client/src/com/acme/services/buyer/WSBuyerClient.java 2009-08-17 08:36:30 UTC (rev 752) +++ cdl/trunk/samples/jbossesb/client/src/com/acme/services/buyer/WSBuyerClient.java 2009-08-18 06:09:57 UTC (rev 753) @@ -54,6 +54,7 @@ String msg = new String(StreamUtils.readStream(WSBuyerClient.class.getResourceAsStream("/soap_message_" + messageNum + ".xml"))); return msg; } + /** * @param args Modified: cdl/trunk/samples/jbossesb/common/creditAgency/src/main/java/org/jboss/overlord/examples/creditAgency/CreditAgencyDecision.java =================================================================== --- cdl/trunk/samples/jbossesb/common/creditAgency/src/main/java/org/jboss/overlord/examples/creditAgency/CreditAgencyDecision.java 2009-08-17 08:36:30 UTC (rev 752) +++ cdl/trunk/samples/jbossesb/common/creditAgency/src/main/java/org/jboss/overlord/examples/creditAgency/CreditAgencyDecision.java 2009-08-18 06:09:57 UTC (rev 753) @@ -20,7 +20,10 @@ package org.jboss.overlord.examples.creditAgency; import org.jboss.savara.jbossesb.Decision; +import org.jboss.savara.jbossesb.XMLUtils; import org.jboss.soa.esb.message.Message; +import org.w3c.dom.Node; +import org.w3c.dom.NodeList; /** * @author <a href="mailto:cyu@redhat.com">Jeff Yu</a> @@ -28,11 +31,29 @@ */ public class CreditAgencyDecision implements Decision { - /* (non-Javadoc) + /* * @see org.jboss.soa.overlord.jbossesb.Decision#executeDecision(org.jboss.soa.esb.message.Message) + * + * return true if amount is less than 500. + * */ public boolean executeDecision(Message message) { - return true; + try { + String xmlMsg = (String)message.getBody().get(); + Node node = XMLUtils.getNode(xmlMsg); + NodeList nodeList = node.getChildNodes(); + for (int i =0; i < nodeList.getLength(); i++) { + if ("amount".equals(nodeList.item(i).getNodeName())) { + String value = nodeList.item(i).getTextContent(); + if (500 >= Integer.valueOf(value).intValue()) { + return true; + } + } + } + return false; + } catch (Exception e) { + return false; + } } } Modified: cdl/trunk/samples/jbossesb/common/creditAgency/src/main/java/org/jboss/overlord/examples/creditAgency/SetCreditCheckInvalidMessageAction.java =================================================================== --- cdl/trunk/samples/jbossesb/common/creditAgency/src/main/java/org/jboss/overlord/examples/creditAgency/SetCreditCheckInvalidMessageAction.java 2009-08-17 08:36:30 UTC (rev 752) +++ cdl/trunk/samples/jbossesb/common/creditAgency/src/main/java/org/jboss/overlord/examples/creditAgency/SetCreditCheckInvalidMessageAction.java 2009-08-18 06:09:57 UTC (rev 753) @@ -25,6 +25,7 @@ import org.jboss.soa.esb.helpers.ConfigTree; import org.jboss.soa.esb.message.Message; import org.w3c.dom.Node; +import org.w3c.dom.NodeList; public class SetCreditCheckInvalidMessageAction extends AbstractActionLifecycle { @@ -37,10 +38,25 @@ } public Message process(Message message) throws Exception{ + StringBuffer sbuffer = new StringBuffer(); Node node = XMLUtils.getNode((String)message.getBody().get()); String idValue = node.getAttributes().getNamedItem("id").getNodeValue(); - message.getBody().add("<CreditCheckInvalid id=\"" + idValue +"\"></CreditCheckInvalid>"); + sbuffer.append("<CreditCheckInvalid id=\"" + idValue +"\">"); + + NodeList list = node.getChildNodes(); + for (int i =0; i < list.getLength(); i++) { + if ("amount".equals(list.item(i).getNodeName())) { + sbuffer.append("<amount>" + list.item(i).getTextContent() + "</amount>"); + } + if ("account".equals(list.item(i).getNodeName())) { + sbuffer.append("<account>" + list.item(i).getTextContent()+"</account>"); + } + } + + sbuffer.append("</CreditCheckInvalid>"); + + message.getBody().add(sbuffer.toString()); logger.info("Updated credit message: " + message.getBody().get()); Modified: cdl/trunk/samples/jbossesb/common/creditAgency/src/main/java/org/jboss/overlord/examples/creditAgency/SetCreditCheckResponseMessageAction.java =================================================================== --- cdl/trunk/samples/jbossesb/common/creditAgency/src/main/java/org/jboss/overlord/examples/creditAgency/SetCreditCheckResponseMessageAction.java 2009-08-17 08:36:30 UTC (rev 752) +++ cdl/trunk/samples/jbossesb/common/creditAgency/src/main/java/org/jboss/overlord/examples/creditAgency/SetCreditCheckResponseMessageAction.java 2009-08-18 06:09:57 UTC (rev 753) @@ -25,6 +25,7 @@ import org.jboss.soa.esb.helpers.ConfigTree; import org.jboss.soa.esb.message.Message; import org.w3c.dom.Node; +import org.w3c.dom.NodeList; public class SetCreditCheckResponseMessageAction extends AbstractActionLifecycle { @@ -37,11 +38,26 @@ } public Message process(Message message) throws Exception{ + StringBuffer sbuffer = new StringBuffer(); Node node = XMLUtils.getNode((String)message.getBody().get()); String idValue = node.getAttributes().getNamedItem("id").getNodeValue(); - message.getBody().add("<CreditCheckOk id=\"" + idValue +"\"></CreditCheckOk>"); + sbuffer.append("<CreditCheckOk id=\"" + idValue +"\">"); + NodeList list = node.getChildNodes(); + for (int i =0; i < list.getLength(); i++) { + if ("amount".equals(list.item(i).getNodeName())) { + sbuffer.append("<amount>" + list.item(i).getTextContent() + "</amount>"); + } + if ("account".equals(list.item(i).getNodeName())) { + sbuffer.append("<account>" + list.item(i).getTextContent()+"</account>"); + } + } + + sbuffer.append("</CreditCheckOk>"); + + message.getBody().add(sbuffer.toString()); + logger.info("Updated credit message: "+message.getBody().get() +"' by thread of " + Thread.currentThread().getName()); return(message); Modified: cdl/trunk/samples/jbossesb/common/creditAgency/src/main/java/org/jboss/overlord/examples/wsdl/CreditAgencyService.java =================================================================== --- cdl/trunk/samples/jbossesb/common/creditAgency/src/main/java/org/jboss/overlord/examples/wsdl/CreditAgencyService.java 2009-08-17 08:36:30 UTC (rev 752) +++ cdl/trunk/samples/jbossesb/common/creditAgency/src/main/java/org/jboss/overlord/examples/wsdl/CreditAgencyService.java 2009-08-18 06:09:57 UTC (rev 753) @@ -26,6 +26,15 @@ import javax.jws.soap.SOAPBinding; import org.jboss.overlord.examples.xsd.PurchaseDetailsType; +import org.jboss.savara.jbossesb.MessageUtil; +import org.jboss.savara.jbossesb.XMLUtils; +import org.jboss.soa.esb.client.ServiceInvoker; +import org.jboss.soa.esb.listeners.message.MessageDeliverException; +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.w3c.dom.Node; +import org.w3c.dom.NodeList; /** @@ -41,11 +50,55 @@ public PurchaseDetailsType checkCredit(@WebParam(name = "CreditCheckRequest", partName = "CreditCheckRequest") PurchaseDetailsType creditCheckRequest) throws CreditCheckInvalid { - System.out.println("The amount is: " + creditCheckRequest.getAmount()); - if (creditCheckRequest.getAmount() >= 500) { - CreditCheckInvalid invalid = new CreditCheckInvalid(null, creditCheckRequest); - throw invalid; - } - return creditCheckRequest; + Message message = getRequestMessage(creditCheckRequest); + + try { + ServiceInvoker invoker = new ServiceInvoker("org.pi4soa.purchase.purchasegoods", "PurchaseGoodsProcess_CreditAgency"); + Message response = invoker.deliverSync(message, 20000); + + PurchaseDetailsType result = getConvertedResponse(response); + + String messageType = MessageUtil.getMessageType(response.getBody().get()); + if ("CreditCheckInvalid".equalsIgnoreCase(messageType)) { + throw new CreditCheckInvalid(null, result); + } + return result; + } catch (Exception e) { + throw new CreditCheckInvalid(null, creditCheckRequest); + } + } + + private PurchaseDetailsType getConvertedResponse(Message response) throws Exception { + Node node = XMLUtils.getNode((String)response.getBody().get()); + String idValue = node.getAttributes().getNamedItem("id").getNodeValue(); + String amountNo = null; + String accountNo = null; + NodeList list = node.getChildNodes(); + for (int i =0; i < list.getLength(); i++) { + if ("amount".equals(list.item(i).getNodeName())) { + amountNo = list.item(i).getTextContent(); + } + if ("account".equals(list.item(i).getNodeName())) { + accountNo = list.item(i).getTextContent(); + } + } + + PurchaseDetailsType result = new PurchaseDetailsType(); + result.setId(Integer.valueOf(idValue)); + result.setAccount(Integer.valueOf(accountNo)); + result.setAmount(Integer.valueOf(amountNo)); + return result; + } + + private Message getRequestMessage(PurchaseDetailsType creditCheckRequest) { + Message message = MessageFactory.getInstance().getMessage(MessageType.JBOSS_XML); + StringBuffer sbuffer = new StringBuffer(); + sbuffer.append("<CreditCheckRequest id=\"" + creditCheckRequest.getId() +"\">"); + sbuffer.append("<account>" + creditCheckRequest.getAccount() + "</account>"); + sbuffer.append("<amount>" + creditCheckRequest.getAmount() + "</amount>"); + sbuffer.append("</CreditCheckRequest>"); + message.getBody().add(sbuffer.toString()); + return message; + } } Modified: cdl/trunk/samples/jbossesb/common/creditAgency/src/main/resources/META-INF/jboss-esb.xml =================================================================== --- cdl/trunk/samples/jbossesb/common/creditAgency/src/main/resources/META-INF/jboss-esb.xml 2009-08-17 08:36:30 UTC (rev 752) +++ cdl/trunk/samples/jbossesb/common/creditAgency/src/main/resources/META-INF/jboss-esb.xml 2009-08-18 06:09:57 UTC (rev 753) @@ -39,7 +39,7 @@ <listeners> <jms-listener busidref="busId1" maxThreads="1" name="esb-stateless-creditAgency"/> </listeners> - <actions mep="OneWay"> + <actions mep="OneWay"> <action name="c1" process="process" class="org.jboss.savara.jbossesb.actions.SwitchAction"> <property name="serviceDescriptionName" value="{org.pi4soa.purchase.purchasegoods}PurchaseGoodsProcess-CreditAgency"/> <property name="conversationType" value="overlord.cdl.samples.Common@CreditAgency"/>