[jboss-svn-commits] JBL Code SVN: r15877 - in labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb: samples/quickstart/aggregator and 1 other directory.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Wed Oct 17 07:49:25 EDT 2007
Author: tfennelly
Date: 2007-10-17 07:49:25 -0400 (Wed, 17 Oct 2007)
New Revision: 15877
Modified:
labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/dvdstore/DVDStoreAction.java
labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/dvdstore/RetrieveCustomerAction.java
labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/dvdstore/RetrieveLineItemsAction.java
labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/dvdstore/RetrieveOrderAction.java
labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/samples/quickstart/aggregator/MyJMSListenerAction.java
labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/samples/quickstart/aggregator/ReturnJMSMessage.java
labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/samples/quickstart/aggregator/TeamAlert.java
Log:
Updates to reflect new message stuff
Modified: labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/dvdstore/DVDStoreAction.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/dvdstore/DVDStoreAction.java 2007-10-17 11:44:42 UTC (rev 15876)
+++ labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/dvdstore/DVDStoreAction.java 2007-10-17 11:49:25 UTC (rev 15877)
@@ -42,30 +42,26 @@
}
public Message process(Message message) throws ActionProcessingException {
- HashMap beanHash = (HashMap) message.getBody().get("EXTRACTED_BEANS_HASH");
-
- StringBuffer results = new StringBuffer();
- if(beanHash != null) {
- OrderHeader header = (OrderHeader) beanHash.get("orderHeader");
- Customer customer = (Customer) beanHash.get("customer");
- List orderItems = (List) beanHash.get("orderItemList");
- results.append("Demonstrates Smooks ability to rip the XML into Objects\n");
- results.append("********* DVDStoreAction - Order Value Objects Populated *********\n");
- results.append("Header: " + header + "\n");
- results.append("Customer: " + customer + "\n");
- if(orderItems != null) {
- results.append("Order Items (" + orderItems.size() + "):\n");
- for(int i = 0; i < orderItems.size(); i++) {
- results.append("\t" + i + ": " + orderItems.get(i) + "\n");
- }
- }
- results.append("\n****************************************************************** ");
- } else {
- results.append("\n*** No beanhash found!");
- }
-
+ StringBuffer results = new StringBuffer();
+ OrderHeader header = (OrderHeader) message.getBody().get("orderHeader");
+ Customer customer = (Customer) message.getBody().get("customer");
+ List orderItems = (List) message.getBody().get("orderItemList");
+
+ results.append("Demonstrates Smooks ability to rip the XML into Objects\n");
+ results.append("********* DVDStoreAction - Order Value Objects Populated *********\n");
+ results.append("Header: " + header + "\n");
+ results.append("Customer: " + customer + "\n");
+ if(orderItems != null) {
+ results.append("Order Items (" + orderItems.size() + "):\n");
+ for(int i = 0; i < orderItems.size(); i++) {
+ results.append("\t" + i + ": " + orderItems.get(i) + "\n");
+ }
+ }
+ results.append("\n****************************************************************** ");
+
// Take this "parsed" output and make it a new message
- message.getBody().setByteArray(results.toString().getBytes());
+ message.getBody().add(results.toString());
+
return message;
}
}
Modified: labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/dvdstore/RetrieveCustomerAction.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/dvdstore/RetrieveCustomerAction.java 2007-10-17 11:44:42 UTC (rev 15876)
+++ labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/dvdstore/RetrieveCustomerAction.java 2007-10-17 11:49:25 UTC (rev 15877)
@@ -41,16 +41,12 @@
}
public Message process(Message message) throws ActionProcessingException {
- HashMap transformedMsg = (HashMap) message.getBody().get("EXTRACTED_BEANS_HASH");
-
- StringBuffer results = new StringBuffer();
- if(transformedMsg != null) {
- Customer customer = (Customer) transformedMsg.get("customer");
- results.append("Customer: " + customer);
- } else {
- results.append("\n*** No beanhash found, failed to transform");
- }
- message.getBody().setByteArray(results.toString().getBytes());
+ StringBuffer results = new StringBuffer();
+ Customer customer = (Customer) message.getBody().get("customer");
+
+ results.append("Customer: " + customer);
+ message.getBody().add(results.toString());
+
return message;
}
}
Modified: labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/dvdstore/RetrieveLineItemsAction.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/dvdstore/RetrieveLineItemsAction.java 2007-10-17 11:44:42 UTC (rev 15876)
+++ labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/dvdstore/RetrieveLineItemsAction.java 2007-10-17 11:49:25 UTC (rev 15877)
@@ -42,23 +42,19 @@
}
public Message process(Message message) throws ActionProcessingException {
- HashMap transformedMsg = (HashMap) message.getBody().get("EXTRACTED_BEANS_HASH");
-
- StringBuffer results = new StringBuffer();
- if(transformedMsg != null) {
- List orderItems = (List) transformedMsg.get("orderItemList");
- if(orderItems != null) {
- results.append("Order Items (" + orderItems.size() + "):");
- for(int i = 0; i < orderItems.size(); i++) {
- results.append("\n" + i + ": " + orderItems.get(i));
- }
- }
- } else {
- results.append("\n*** No beanhash found!");
- }
-
+ StringBuffer results = new StringBuffer();
+ List orderItems = (List) message.getBody().get("orderItemList");
+
+ if(orderItems != null) {
+ results.append("Order Items (" + orderItems.size() + "):");
+ for(int i = 0; i < orderItems.size(); i++) {
+ results.append("\n" + i + ": " + orderItems.get(i));
+ }
+ }
+
// Take this "parsed" output and make it a new message
- message.getBody().setByteArray(results.toString().getBytes());
- return message;
+ message.getBody().add(results.toString());
+
+ return message;
}
}
Modified: labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/dvdstore/RetrieveOrderAction.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/dvdstore/RetrieveOrderAction.java 2007-10-17 11:44:42 UTC (rev 15876)
+++ labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/dvdstore/RetrieveOrderAction.java 2007-10-17 11:49:25 UTC (rev 15877)
@@ -21,8 +21,6 @@
package org.jboss.soa.esb.dvdstore;
-import java.util.HashMap;
-
import org.jboss.soa.esb.actions.AbstractActionPipelineProcessor;
import org.jboss.soa.esb.actions.ActionProcessingException;
import org.jboss.soa.esb.helpers.ConfigTree;
@@ -41,19 +39,12 @@
}
public Message process(Message message) throws ActionProcessingException {
- HashMap transformedMsg = (HashMap) message.getBody().get("EXTRACTED_BEANS_HASH");
-
- StringBuffer results = new StringBuffer();
- if(transformedMsg != null) {
- OrderHeader header = (OrderHeader) transformedMsg.get("orderHeader");
-
- results.append(header);
-
- } else {
- results.append("\n*** No beanhash found!");
- }
-
- message.getBody().setByteArray(results.toString().getBytes());
+ StringBuffer results = new StringBuffer();
+ OrderHeader header = (OrderHeader) message.getBody().get("orderHeader");
+
+ results.append(header);
+ message.getBody().add(results.toString());
+
return message;
}
}
Modified: labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/samples/quickstart/aggregator/MyJMSListenerAction.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/samples/quickstart/aggregator/MyJMSListenerAction.java 2007-10-17 11:44:42 UTC (rev 15876)
+++ labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/samples/quickstart/aggregator/MyJMSListenerAction.java 2007-10-17 11:49:25 UTC (rev 15877)
@@ -35,7 +35,7 @@
public Message displayMessage(Message message) throws Exception{
logHeader();
- System.out.println(new String(message.getBody().getByteArray()));
+ System.out.println(message.getBody().get());
logFooter();
return message;
}
@@ -45,7 +45,7 @@
System.out.println("!ERROR!");
System.out.println(exception.getMessage());
System.out.println("For Message: ");
- System.out.println(message.getBody().getByteArray());
+ System.out.println(message.getBody().get());
logFooter();
}
Modified: labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/samples/quickstart/aggregator/ReturnJMSMessage.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/samples/quickstart/aggregator/ReturnJMSMessage.java 2007-10-17 11:44:42 UTC (rev 15876)
+++ labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/samples/quickstart/aggregator/ReturnJMSMessage.java 2007-10-17 11:49:25 UTC (rev 15877)
@@ -21,24 +21,18 @@
package org.jboss.soa.esb.samples.quickstart.aggregator;
import javax.naming.InitialContext;
-import javax.naming.NamingException;
-import javax.jms.JMSException;
import javax.jms.QueueConnectionFactory;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueSession;
import javax.jms.QueueSender;
-import javax.jms.ObjectMessage;
import javax.jms.TextMessage;
-import java.io.File;
-import java.io.FileReader;
-import java.io.IOException;
import org.jboss.soa.esb.message.Message;
public class ReturnJMSMessage {
- public static void sendMessage(Message esbMessage,String newDestination) throws JMSException, NamingException, Exception {
+ public static void sendMessage(Message esbMessage,String newDestination) throws Exception {
if (esbMessage == null || newDestination == null)
throw new Exception("Message and JMS Destination are required");
@@ -54,9 +48,7 @@
session = conn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
conn.start();
-
- String newMsg = new String(esbMessage.getBody().getByteArray());
-
+ String newMsg = (String) esbMessage.getBody().get();
QueueSender send = session.createSender(que);
TextMessage tm = session.createTextMessage(newMsg);
Modified: labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/samples/quickstart/aggregator/TeamAlert.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/samples/quickstart/aggregator/TeamAlert.java 2007-10-17 11:44:42 UTC (rev 15876)
+++ labs/jbossesb/trunk/product/samples/quickstarts/aggregator/src/org/jboss/soa/esb/samples/quickstart/aggregator/TeamAlert.java 2007-10-17 11:49:25 UTC (rev 15877)
@@ -33,7 +33,7 @@
public Message sendResponseBlue(Message message) {
try {
logHeader();
- System.out.println(new String(message.getBody().getByteArray()));
+ System.out.println(message.getBody().get());
System.out.println("Blue Blue Blue");
logFooter();
ReturnJMSMessage.sendMessage(message,"quickstart_Fun_CBR_Blue_Alert");
@@ -48,7 +48,7 @@
public Message sendResponseRed(Message message) {
try {
logHeader();
- System.out.println(new String(message.getBody().getByteArray()));
+ System.out.println(message.getBody().get());
System.out.println("Red Red Red");
logFooter();
ReturnJMSMessage.sendMessage(message,"quickstart_Fun_CBR_Red_Alert");
@@ -63,7 +63,7 @@
public Message sendResponseGreen(Message message) {
try {
logHeader();
- System.out.println(new String(message.getBody().getByteArray()));
+ System.out.println(message.getBody().get());
System.out.println("Green Green Green");
logFooter();
ReturnJMSMessage.sendMessage(message,"quickstart_Fun_CBR_Green_Alert");
More information about the jboss-svn-commits
mailing list