[jboss-svn-commits] JBL Code SVN: r15885 - in labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration3: src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration3/esb_actions and 1 other directory.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Wed Oct 17 10:45:33 EDT 2007
Author: tfennelly
Date: 2007-10-17 10:45:33 -0400 (Wed, 17 Oct 2007)
New Revision: 15885
Modified:
labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration3/scripts/service1.groovy
labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration3/scripts/service2.groovy
labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration3/scripts/service3.groovy
labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration3/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration3/esb_actions/MessageSpy.java
labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration3/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration3/esb_actions/SetupSignal.java
labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration3/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration3/esb_actions/SimpleJMSNotifier.java
Log:
Updates to reflect new message stuff
Modified: labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration3/scripts/service1.groovy
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration3/scripts/service1.groovy 2007-10-17 14:41:59 UTC (rev 15884)
+++ labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration3/scripts/service1.groovy 2007-10-17 14:45:33 UTC (rev 15885)
@@ -2,12 +2,12 @@
println "** Begin Service 1 **"
-println "In: " + new String(message.body.contents)
+println "In: " + message.getBody().get()
println "jbpmTokenId: " + message.body.get("jbpmTokenId")
-message.body.contents = (new String(message.body.contents) + " 'Service 1' ").getBytes()
+message.getBody().add(message.getBody().get() + " 'Service 1' ")
-println "Out: " + new String(message.body.contents)
+println "Out: " + message.getBody().get()
println "** End Service 1 **"
Modified: labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration3/scripts/service2.groovy
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration3/scripts/service2.groovy 2007-10-17 14:41:59 UTC (rev 15884)
+++ labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration3/scripts/service2.groovy 2007-10-17 14:45:33 UTC (rev 15885)
@@ -2,12 +2,12 @@
println "** Begin Service 2 **"
-println "In: " + new String(message.body.contents)
+println "In: " + message.getBody().get()
println "jbpmTokenId: " + message.body.get("jbpmTokenId")
-message.body.contents = (new String(message.body.contents) + " 'Service 2' ").getBytes()
+message.getBody().add(message.getBody().get() + " 'Service 2' ")
-println "Out: " + new String(message.body.contents)
+println "Out: " + message.getBody().get()
println "** End Service 2 **"
Modified: labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration3/scripts/service3.groovy
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration3/scripts/service3.groovy 2007-10-17 14:41:59 UTC (rev 15884)
+++ labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration3/scripts/service3.groovy 2007-10-17 14:45:33 UTC (rev 15885)
@@ -2,10 +2,10 @@
println "** Begin Service 3 **"
-println "In: " + new String(message.body.contents)
+println "In: " + message.getBody().get()
-message.body.contents = (new String(message.body.contents) + " 'Service 3' ").getBytes()
+message.getBody().add(message.getBody().get() + " 'Service 3' ")
-println "Out: " + new String(message.body.contents)
+println "Out: " + message.getBody().get()
println "** End Service 3 **"
\ No newline at end of file
Modified: labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration3/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration3/esb_actions/MessageSpy.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration3/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration3/esb_actions/MessageSpy.java 2007-10-17 14:41:59 UTC (rev 15884)
+++ labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration3/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration3/esb_actions/MessageSpy.java 2007-10-17 14:45:33 UTC (rev 15885)
@@ -33,12 +33,16 @@
// modify to use the logger
public Message process(Message message) throws Exception {
- if (message.getBody() != null && message.getBody().getByteArray() != null) {
- logger.info("Body: " + new String(message.getBody().getByteArray()));
- } else {
- logger.info("Body Contents are NULL");
- }
- return message;
+ Object payload = message.getBody().get();
+
+ if (payload instanceof byte[]) {
+ logger.info("Body: " + new String((byte[])payload));
+ } else if (payload instanceof String) {
+ logger.info("Body: " + payload);
+ } else {
+ logger.info("Body Contents are NULL");
+ }
+ return message;
}
public MessageSpy(ConfigTree config) { _config = config; }
Modified: labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration3/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration3/esb_actions/SetupSignal.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration3/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration3/esb_actions/SetupSignal.java 2007-10-17 14:41:59 UTC (rev 15884)
+++ labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration3/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration3/esb_actions/SetupSignal.java 2007-10-17 14:45:33 UTC (rev 15885)
@@ -41,8 +41,8 @@
message.getBody().add("jbpmTokenId",token);
- if (message.getBody() != null && message.getBody().getByteArray() != null) {
- logger.info("Body: " + new String(message.getBody().getByteArray()));
+ if (message.getBody() != null && message.getBody().get() != null) {
+ logger.info("Body: " + message.getBody().get());
} else {
logger.info("Body Contents are NULL");
}
Modified: labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration3/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration3/esb_actions/SimpleJMSNotifier.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration3/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration3/esb_actions/SimpleJMSNotifier.java 2007-10-17 14:41:59 UTC (rev 15884)
+++ labs/jbossesb/trunk/product/samples/quickstarts/bpm_orchestration3/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration3/esb_actions/SimpleJMSNotifier.java 2007-10-17 14:45:33 UTC (rev 15885)
@@ -64,7 +64,7 @@
//logger.info("Connection Started");
QueueSender send = session.createSender(que);
- TextMessage tm = session.createTextMessage(new String(message.getBody().getByteArray()));
+ TextMessage tm = session.createTextMessage((String)message.getBody().get());
send.send(tm);
send.close();
More information about the jboss-svn-commits
mailing list