[jboss-svn-commits] JBL Code SVN: r7864 - in labs/jbossesb/trunk/product/samples/trailblazer2: . client/src/org/jboss/soa/esb/samples/trailblazer/loanbroker esb/conf esb/lib/ext esb/src/org/jboss/soa/esb/samples/trailblazer/util
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Mon Nov 27 21:15:24 EST 2006
Author: daniel.brum at jboss.com
Date: 2006-11-27 21:15:03 -0500 (Mon, 27 Nov 2006)
New Revision: 7864
Added:
labs/jbossesb/trunk/product/samples/trailblazer2/esb/lib/ext/juddi-client.jar
labs/jbossesb/trunk/product/samples/trailblazer2/esb/lib/ext/juddi-embedded.jar
labs/jbossesb/trunk/product/samples/trailblazer2/esb/lib/ext/milyn-smooks-csv-0.1.jar
labs/jbossesb/trunk/product/samples/trailblazer2/esb/lib/ext/opencsv-1.6.jar
labs/jbossesb/trunk/product/samples/trailblazer2/esb/lib/ext/scout-0.7rc2-embedded.jar
Modified:
labs/jbossesb/trunk/product/samples/trailblazer2/build.xml
labs/jbossesb/trunk/product/samples/trailblazer2/client/src/org/jboss/soa/esb/samples/trailblazer/loanbroker/LoanBroker.java
labs/jbossesb/trunk/product/samples/trailblazer2/esb/conf/loanbroker-esb.xml
labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/util/Launcher.java
Log:
Modified: labs/jbossesb/trunk/product/samples/trailblazer2/build.xml
===================================================================
--- labs/jbossesb/trunk/product/samples/trailblazer2/build.xml 2006-11-28 02:14:40 UTC (rev 7863)
+++ labs/jbossesb/trunk/product/samples/trailblazer2/build.xml 2006-11-28 02:15:03 UTC (rev 7864)
@@ -73,7 +73,8 @@
<fileset dir="${org.jboss.esb.samples.trailblazer.esb.dest}/dist" includes="trailblazer-esb.jar"/>
<fileset dir="${org.jboss.soa.samples.trailblazer.esb_home}/lib/ext" includes="*.jar" excludes="jaxr-api-1.0.jar,scout-0.7rc2-embedded.jar,juddi-embedded.jar"/>
<fileset dir="${org.jboss.soa.samples.trailblazer.jboss_home}/client" includes="jbossall-client.jar jbossws-client.jar mail.jar"/>
- <fileset dir="${org.jboss.soa.samples.trailblazer.esb_home}/build/dist/lib" includes="*.jar"/>
+ <fileset dir="${org.jboss.soa.samples.trailblazer.esb_home}/build/dist/lib" includes="*.jar"/>
+ <fileset dir="${org.jboss.esb.samples.trailblazer.esb.lib.dir}/ext" includes="*.jar"/>
<!-- for finding the jbossesb-properties.xml file -->
<pathelement location="${basedir}"/>
</path>
Modified: labs/jbossesb/trunk/product/samples/trailblazer2/client/src/org/jboss/soa/esb/samples/trailblazer/loanbroker/LoanBroker.java
===================================================================
--- labs/jbossesb/trunk/product/samples/trailblazer2/client/src/org/jboss/soa/esb/samples/trailblazer/loanbroker/LoanBroker.java 2006-11-28 02:14:40 UTC (rev 7863)
+++ labs/jbossesb/trunk/product/samples/trailblazer2/client/src/org/jboss/soa/esb/samples/trailblazer/loanbroker/LoanBroker.java 2006-11-28 02:15:03 UTC (rev 7864)
@@ -23,18 +23,18 @@
import java.io.IOException;
-import java.util.Collection;
-import java.util.Iterator;
import javax.xml.parsers.ParserConfigurationException;
import org.apache.log4j.Logger;
import org.jboss.soa.esb.actions.ActionProcessingException;
-import org.jboss.soa.esb.actions.ActionUtils;
+import org.jboss.soa.esb.addressing.Call;
import org.jboss.soa.esb.addressing.EPR;
+import org.jboss.soa.esb.addressing.eprs.JMSEpr;
import org.jboss.soa.esb.common.ModulePropertyManager;
import org.jboss.soa.esb.couriers.Courier;
import org.jboss.soa.esb.couriers.CourierFactory;
+import org.jboss.soa.esb.couriers.CourierTimeoutException;
import org.jboss.soa.esb.couriers.CourierUtil;
import org.jboss.soa.esb.couriers.TwoWayCourier;
import org.jboss.soa.esb.message.Message;
@@ -73,76 +73,72 @@
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 - get the credit score for this customer
- //use a CSV delimited String
+ CustomerMasterFile.addCustomer(String.valueOf(customer.ssn), customer);
+
Message message = MessageFactory.getInstance().getMessage(MessageType.JBOSS_XML);
- message.getBody().setContents(customer.getCSV().getBytes());
-// ActionUtils.setTaskObject(message, customer.getCSV());
- try {
- System.out.println("message: " + Util.serialize(message));
- } catch (ParserConfigurationException e1) {
- // TODO Auto-generated catch block
- e1.printStackTrace();
- } catch (IOException e1) {
- // TODO Auto-generated catch block
- e1.printStackTrace();
- }
+ Message replyMessage=null;
+ //convert our customer to a bean xml representation
+// XMLEncoder encoder=null;
+// try {
+// ByteArrayOutputStream bytes = new ByteArrayOutputStream();
+// ObjectOutputStream oos = new ObjectOutputStream(bytes);
+// encoder = new XMLEncoder(oos);
+// encoder.writeObject(wCustomer);
+// encoder.close();
+// System.out.println("encoded customer: "+ bytes.toString());
+// } catch (IOException e2) {
+// // TODO Auto-generated catch block
+// e2.printStackTrace();
+// }
+
+ //set the customer inside the message - csv format for now to test
+ message.getBody().setContents(customer.getCSV().getBytes());
+
try {
+ //registry setup stuff
Registry registry = RegistryFactory.getRegistry();
String serviceCategoryName = ModulePropertyManager.getPropertyManager(MODULE_NAME).getProperty(SERVICE_CAT);
- String serviceName = ModulePropertyManager.getPropertyManager(MODULE_NAME).getProperty(SERVICE_NAME);
+ String serviceName = ModulePropertyManager.getPropertyManager(MODULE_NAME).getProperty(SERVICE_NAME);
+ logger.debug("looking for the following service in the registry -- Category: " + serviceCategoryName);
+ logger.debug("looking for the following service in the registry -- Name: " + serviceName);
- logger.info("looking for the following service in the registry -- Category: " + serviceCategoryName);
- logger.info("looking for the following service in the registry -- Name: " + serviceName);
+ //EPRs to use for delivery and reply messages
+ EPR toEPR=null, replyEPR=null;
- EPR toEPR=null;
- toEPR = registry.findEPR(serviceCategoryName, serviceName);
- Courier courier = CourierFactory.getCourier(toEPR, null);
+ //find the service in the registry
+ toEPR = (JMSEpr)registry.findEPR(serviceCategoryName, serviceName);
+
+ //use a 2-way courier so we can grab the response
+ TwoWayCourier courier = CourierFactory.getCourier(toEPR, null);
+
+ if (message.getHeader().getCall()==null) {
+ Call call = new Call();
+ message.getHeader().setCall(call);
+ }
+
if (null == courier) {
logger.info("could not get a valid courier to deliver the message");
throw new ActionProcessingException("could not find a courier to deliver the message for the serrvice " +
- "(category-name: " + serviceCategoryName +"-" + serviceCategoryName);
- }
- if (null != courier) {
- if (!courier.deliver(message)) {
- throw new ActionProcessingException("error delivering the message");
- }
-// courier.setReplyToEpr(CourierUtil.getTemporaryReplyToEpr(toEPR));
-// message = courier.pickup(5000);
-
- }
+ "(category-name: " + serviceCategoryName +"-" + serviceCategoryName); }
- System.out.println("message returned: " + Util.serialize(message));
+ replyEPR = CourierUtil.getTemporaryReplyToEpr(toEPR);
+ message.getHeader().getCall().setReplyTo(replyEPR);
+ if (courier.deliver(message)) {
+ courier.setReplyToEpr(replyEPR);
+ replyMessage = courier.pickup(5000); //TODO: replace with a time value from Config
+ logger.debug("received reply from creditAgency action");
+ logger.debug("message received: " + replyMessage.getBody().getContents());
+ } else
+ throw new ActionProcessingException("error delivering the message to the credit agency");
-
-// for (Iterator<EPR> eprIterator=eprs.iterator();eprIterator.hasNext();){
-//
-// toEPR = eprIterator.next();
-// courier = CourierFactory.getCourier(toEPR, null);
-// if (null == courier) {
-// logger.info("could not get a valid courier to deliver the message");
-// break;
-// }
-//
-// //If not successful try the next EPR
-// if (courier.deliver(message)) {
-// break;
-// }
-// }
-// //get the response
-// if (null != courier)
-// replytToEPR = CourierUtil.getTemporaryReplyToEpr(toEPR);
-//
-//
-// CourierFactory.getCourier(toEPR, replytToEPR);
-//
- }catch (Exception e) {
- logger.error("exception occured: " + e);
+ }catch(CourierTimeoutException ex1) {
+ logger.error("timeout occured waiting for creditAgency response - " + ex1);
+ }catch (Exception ex2) {
+ logger.error("exception occured: " + ex2);
+ ex2.printStackTrace();
}
//step 2 - send to JMS Bank
Modified: labs/jbossesb/trunk/product/samples/trailblazer2/esb/conf/loanbroker-esb.xml
===================================================================
--- labs/jbossesb/trunk/product/samples/trailblazer2/esb/conf/loanbroker-esb.xml 2006-11-28 02:14:40 UTC (rev 7863)
+++ labs/jbossesb/trunk/product/samples/trailblazer2/esb/conf/loanbroker-esb.xml 2006-11-28 02:15:03 UTC (rev 7864)
@@ -11,15 +11,15 @@
jndi-URL="localhost"
message-selector="service='creditAgency'"
maxThreads="2"
- >
- <action class="org.jboss.soa.esb.samples.trailblazer.actions.CreditAgencyActions" process="debugMessage"/>
+ >
<action class="org.jboss.soa.esb.samples.trailblazer.actions.CreditAgencyActions" process="processCreditRequest"/>
- <xxxaction class="org.jboss.soa.esb.actions.converters.SmooksTransformer"
+ <!-- action class="org.jboss.soa.esb.actions.converters.SmooksTransformer"
from-type="text/csv:CreditCheck"
from-epr="trailblazer:loanbroker"
to-type="text/xml:CreditCheck"
- to-epr="trailblazer:creditcheck"/>
+ to-epr="trailblazer:creditcheck" -->
+
</CreditCheck>
</Trailblazer>
Added: labs/jbossesb/trunk/product/samples/trailblazer2/esb/lib/ext/juddi-client.jar
===================================================================
(Binary files differ)
Property changes on: labs/jbossesb/trunk/product/samples/trailblazer2/esb/lib/ext/juddi-client.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: labs/jbossesb/trunk/product/samples/trailblazer2/esb/lib/ext/juddi-embedded.jar
===================================================================
(Binary files differ)
Property changes on: labs/jbossesb/trunk/product/samples/trailblazer2/esb/lib/ext/juddi-embedded.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: labs/jbossesb/trunk/product/samples/trailblazer2/esb/lib/ext/milyn-smooks-csv-0.1.jar
===================================================================
(Binary files differ)
Property changes on: labs/jbossesb/trunk/product/samples/trailblazer2/esb/lib/ext/milyn-smooks-csv-0.1.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: labs/jbossesb/trunk/product/samples/trailblazer2/esb/lib/ext/opencsv-1.6.jar
===================================================================
(Binary files differ)
Property changes on: labs/jbossesb/trunk/product/samples/trailblazer2/esb/lib/ext/opencsv-1.6.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: labs/jbossesb/trunk/product/samples/trailblazer2/esb/lib/ext/scout-0.7rc2-embedded.jar
===================================================================
(Binary files differ)
Property changes on: labs/jbossesb/trunk/product/samples/trailblazer2/esb/lib/ext/scout-0.7rc2-embedded.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Modified: labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/util/Launcher.java
===================================================================
--- labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/util/Launcher.java 2006-11-28 02:14:40 UTC (rev 7863)
+++ labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/util/Launcher.java 2006-11-28 02:15:03 UTC (rev 7864)
@@ -32,8 +32,7 @@
if (args.length==0) {
arg0 = "60";
if (TestEnvironmentUtil.getUserDir("trailblazer2").equals("trailblazer2/")) {
- baseDir = "product/samples/trailblazer2/";
- System.setProperty("org.jboss.soa.esb.propertyFile", baseDir + "loanbroker-properties.xml");
+ baseDir = "product/samples/trailblazer2/";
}
arg1 = baseDir + "esb/conf/loanbroker-esb.xml";
System.out.println("Setting default arguments:" + arg0 + " " + arg1);
More information about the jboss-svn-commits
mailing list