[jboss-svn-commits] JBL Code SVN: r16799 - in labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts: bpm_orchestration1/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration1/test and 42 other directories.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Sun Nov 25 23:09:18 EST 2007
Author: tcunning
Date: 2007-11-25 23:09:17 -0500 (Sun, 25 Nov 2007)
New Revision: 16799
Added:
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/jms_topic/src/org/jboss/soa/esb/samples/quickstart/jmstopic/SendJMSMessage.java
Modified:
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/bpm_orchestration1/jboss-esb-unfiltered.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/bpm_orchestration1/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration1/test/SendTestMessage.java
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/bpm_orchestration2/jboss-esb.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/bpm_orchestration3/build.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/bpm_orchestration3/jboss-esb.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/bpm_orchestration3/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration3/esb_actions/SimpleJMSNotifier.java
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/bpm_orchestration3/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration3/test/SendJMSMessage.java
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/business_rules_service/jboss-esb.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/business_rules_service/src/org/jboss/soa/esb/samples/quickstart/businessrules/test/SendJMSMessage.java
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/deadletter/jboss-esb.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/deadletter/src/org/jboss/soa/esb/samples/quickstart/deadletter/MyFailingAsyncAction.java
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/deadletter/src/org/jboss/soa/esb/samples/quickstart/deadletter/MyFailingSyncAction.java
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/deadletter/src/org/jboss/soa/esb/samples/quickstart/deadletter/test/SendJMSMessage.java
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/exceptions_faults/build.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/exceptions_faults/jboss-esb.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/fun_cbr/jboss-esb.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/fun_cbr/src/org/jboss/soa/esb/samples/quickstart/funcbr/test/SendJMSMessage.java
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/groovy_gateway/jboss-esb.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/helloworld_action/jboss-esb.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/helloworld_action/src/org/jboss/soa/esb/samples/quickstart/helloworldaction/test/SendJMSMessage.java
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/helloworld_file_notifier/build.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/helloworld_file_notifier/jboss-esb-unfiltered.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/jms_topic/build.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/jms_topic/jboss-esb.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/load_generator/build.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/load_generator/jboss-esb.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/load_generator/scripts/JmsLoadAgent.groovy
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/messagefilter/jboss-esb.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/messagefilter/src/org/jboss/soa/esb/samples/quickstart/messagefilter/test/SendJMSMessage.java
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/messagestore/jboss-esb.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/scheduled_services/jboss-esb.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/scheduled_services/src/org/jboss/soa/esb/samples/quickstart/scheduler/MyScheduledActionMsgComposer.java
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/scheduled_services/src/org/jboss/soa/esb/samples/quickstart/scheduler/test/SendEsbMessage.java
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/simple_cbr/jboss-esb.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/simple_cbr/src/org/jboss/soa/esb/samples/quickstart/simplecbr/test/SendJMSMessage.java
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/spring_aop/jboss-esb.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/spring_aop/src/org/jboss/soa/esb/samples/quickstart/spring_aop/MySpringEnabledAction.java
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/spring_aop/src/org/jboss/soa/esb/samples/quickstart/spring_aop/test/SendJMSMessage.java
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/spring_helloworld/jboss-esb.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/spring_helloworld/src/org/jboss/soa/esb/samples/quickstart/spring_helloworld/test/SendJMSMessage.java
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/spring_jpetstore/jboss-esb.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/spring_jpetstore/src/org/jboss/soa/esb/samples/quickstart/spring_jpetstore/test/SendJMSMessage.java
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_consumer1/build.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_consumer1/jboss-esb.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_consumer1/src/org/jboss/soa/esb/samples/quickstart/webservice_consumer1/test/SendEsbMessage.java
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_consumer2/build.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_consumer2/jboss-esb.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_consumer2/src/org/jboss/soa/esb/samples/quickstart/webservice_consumer2/test/SendEsbMessage.java
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_mtom/jboss-esb.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_producer/jboss-esb.xml
labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_producer/src/org/jboss/soa/esb/samples/quickstart/webserviceproducer/test/SendMessage.java
Log:
bug:JBESB-1154
Changes to integrate remaining QS's into CI.
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/bpm_orchestration1/jboss-esb-unfiltered.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/bpm_orchestration1/jboss-esb-unfiltered.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/bpm_orchestration1/jboss-esb-unfiltered.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -84,12 +84,18 @@
<fs-listener name="ESB-Listener" busidref="deployEsbChannel"
maxThreads="1"/>
</listeners>
- <actions>
+ <actions>
+ <action name="AddProperty"
+ class="org.jboss.soa.esb.actions.PropertySetter">
+ <property name="jbesbfilename" value="BPMOrchestration1Test.log"/>
+ </action>
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
<action name="DeployFromFile"
class="org.jboss.soa.esb.services.jbpm.actions.BpmProcessor">
<property name="command" value="DeployProcessDefinition" />
<property name="process-definition-file" value="/processdefinition.xml" />
- </action>
+ </action>
+
</actions>
</service>
@@ -105,7 +111,11 @@
<actions>
<action name="spy1"
class="org.jboss.soa.esb.samples.quickstarts.bpm_orchestration1.esb_actions.MessageSpy"/>
-
+ <action name="AddProperty"
+ class="org.jboss.soa.esb.actions.PropertySetter">
+ <property name="jbesbfilename" value="BPMOrchestration1Test.log"/>
+ </action>
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
<!-- move the body.getContents() into jBPM -->
<action name="create_new_process_instance"
class="org.jboss.soa.esb.services.jbpm.actions.BpmProcessor">
@@ -139,7 +149,7 @@
<action name="spy3"
class="org.jboss.soa.esb.samples.quickstarts.bpm_orchestration1.esb_actions.MessageSpy"/>
-
+
</actions>
</service>
@@ -164,7 +174,8 @@
<actions>
<action name="groovy" class="org.jboss.soa.esb.actions.scripting.GroovyActionProcessor">
<property name="script" value="/scripts/service2.groovy" />
- </action>
+ </action>
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
</actions>
</service>
<service category="BPM_Orchestration_Service3" name="Service3"
@@ -177,6 +188,7 @@
<action name="groovy" class="org.jboss.soa.esb.actions.scripting.GroovyActionProcessor">
<property name="script" value="/scripts/service3.groovy" />
</action>
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
</actions>
</service>
<service category="BPM_Orchestration_ResultsService" name="ResultsService"
@@ -187,7 +199,8 @@
</listeners>
<actions>
<action name="spy"
- class="org.jboss.soa.esb.samples.quickstarts.bpm_orchestration1.esb_actions.MessageSpy"/>
+ class="org.jboss.soa.esb.samples.quickstarts.bpm_orchestration1.esb_actions.MessageSpy"/>
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
</actions>
</service>
</services>
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/bpm_orchestration1/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration1/test/SendTestMessage.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/bpm_orchestration1/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration1/test/SendTestMessage.java 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/bpm_orchestration1/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration1/test/SendTestMessage.java 2007-11-26 04:09:17 UTC (rev 16799)
@@ -29,27 +29,26 @@
public class SendTestMessage {
public SendTestMessage() {
-
}
- public static void main(String args[]) throws Exception
- {
- System.out.println("Here");
- String inputDirectory = args[0];
- String fileExt = args[1];
- String fileContents = args[2];
-
+
+ public void sendMessage(String inputDirectory, String fileExtension, String fileContents) {
String prefix = Long.toString(Calendar.getInstance().getTimeInMillis());
- File x = File.createTempFile(prefix + "_",fileExt,new File(inputDirectory));
-
-
+ File x = null;
try {
+ x = File.createTempFile(prefix + "_",fileExtension,new File(inputDirectory));
BufferedWriter out = new BufferedWriter(new FileWriter(x));
out.write(fileContents.toCharArray());
out.close();
} catch (Exception e) {
System.out.println("Error while writing the file: " + x.getAbsolutePath());
System.out.println(e.getMessage());
- }
+ }
+ }
+
+ public static void main(String args[]) throws Exception
+ {
+ SendTestMessage stm = new SendTestMessage();
+ stm.sendMessage(args[0], args[1], args[2]);
}
}
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/bpm_orchestration2/jboss-esb.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/bpm_orchestration2/jboss-esb.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/bpm_orchestration2/jboss-esb.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -72,6 +72,11 @@
maxThreads="1"/>
</listeners>
<actions>
+ <action name="AddProperty"
+ class="org.jboss.soa.esb.actions.PropertySetter">
+ <property name="jbesbfilename" value="BPMOrchestration2Test.log"/>
+ </action>
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
<action name="DeployFromFile"
class="org.jboss.soa.esb.services.jbpm.actions.BpmProcessor">
<property name="command" value="DeployProcessDefinition" />
@@ -80,8 +85,8 @@
<action name="deployed-message" class="org.jboss.soa.esb.actions.SystemPrintln">
<property name="message" value="Process Definition Deployed" />
</action>
- </actions>
- </service>
+ </actions>
+ </service>
<service category="BPM_Orchestration2_Starter_Service" name="Starter_Service"
description="BPM Orchestration Sample 2: Use this service to start a process instance">
@@ -93,48 +98,27 @@
maxThreads="1"/>
</listeners>
<actions>
-
- <action name="dump1" class="org.jboss.soa.esb.actions.SystemPrintln">
+ <action name="AddProperty"
+ class="org.jboss.soa.esb.actions.PropertySetter">
+ <property name="jbesbfilename" value="BPMOrchestration2Test.log"/>
+ </action>
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
+ <action name="dump1" class="org.jboss.soa.esb.actions.SystemPrintln">
<property name="printfull" value="true"/>
- </action>
- <!--
- <action name="create_new_process_instance"
- class="org.jboss.soa.esb.services.jbpm.actions.BpmProcessor">
- <property name="command" value="NewProcessInstanceCommand" />
- <property name="process-definition-name" value="bpm_orchestration2Process"/>
- <property name="object-paths">
- <object-path esb="BODY_CONTENT" bpm="theBody" />
- </property>
- </action>
-
- <action name="dump2" class="org.jboss.soa.esb.actions.SystemPrintln">
- <property name="printfull" value="true"/>
- </action>
-
- <action name="signal_the_new_process_instance"
+ </action>
+ <action name="start_a_new_process_instance"
class="org.jboss.soa.esb.services.jbpm.actions.BpmProcessor">
- <property name="command" value="SignalCommand" />
- <property name="process-definition-name" value="bpm_orchestration2Process"/>
- <property name="object-paths">
- <object-path esb="BODY_CONTENT" bpm="theBody" />
- </property>
- </action>
- -->
-
- <action name="start_a_new_process_instance"
- class="org.jboss.soa.esb.services.jbpm.actions.BpmProcessor">
<property name="command" value="StartProcessInstanceCommand" />
<property name="process-definition-name" value="bpm_orchestration2Process"/>
<property name="object-paths">
<object-path esb="eVar1" bpm="counter" value="45" />
<object-path esb="BODY_CONTENT" bpm="theBody" />
</property>
- </action>
-
- <action name="dump3" class="org.jboss.soa.esb.actions.SystemPrintln">
+ </action>
+
+ <action name="dump3" class="org.jboss.soa.esb.actions.SystemPrintln">
<property name="printfull" value="true"/>
- </action>
-
+ </action>
</actions>
</service>
@@ -156,7 +140,6 @@
<action name="alert" class="org.jboss.soa.esb.samples.quickstarts.bpm_orchestration2.esb_actions.SimpleJMSNotifier">
<property name="ALERT_QUEUE_NAME" value="quickstart_bpm_orchestration2_service1_Alert" />
</action>
-
</actions>
</service>
<service category="BPM_Orchestration2_Service2" name="Service2"
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/bpm_orchestration3/build.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/bpm_orchestration3/build.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/bpm_orchestration3/build.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -45,6 +45,7 @@
</target>
<target name="startProcess" depends="compile" description="Sends a message to start a new process instance">
+ <echo>TOKEN=$token</echo>
<echo>Sends a message to start a new process instance</echo>
<java fork="yes" classname="org.jboss.soa.esb.samples.quickstarts.bpm_orchestration3.test.SendJMSMessage" failonerror="true">
<arg value="queue/quickstart_bpm_orchestration3_start_Request_gw"/>
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/bpm_orchestration3/jboss-esb.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/bpm_orchestration3/jboss-esb.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/bpm_orchestration3/jboss-esb.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -58,14 +58,19 @@
maxThreads="1"/>
</listeners>
<actions>
+ <action name="AddProperty"
+ class="org.jboss.soa.esb.actions.PropertySetter">
+ <property name="jbesbfilename" value="BPMOrchestration3Test.log"/>
+ </action>
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
<action name="DeployFromFile"
class="org.jboss.soa.esb.services.jbpm.actions.BpmProcessor">
<property name="command" value="DeployProcessDefinition" />
<property name="process-definition-file" value="/processDefinition/processdefinition.xml" />
</action>
- <action name="deployed-message" class="org.jboss.soa.esb.actions.SystemPrintln">
- <property name="message" value="Process Definition Deployed" />
- </action>
+ <action name="deployed-message" class="org.jboss.soa.esb.actions.SystemPrintln">
+ <property name="message" value="Process Definition Deployed" />
+ </action>
</actions>
</service>
@@ -79,13 +84,17 @@
maxThreads="1"/>
</listeners>
<actions>
-
<action name="setupKey" class="org.jboss.soa.esb.samples.quickstarts.bpm_orchestration3.esb_actions.SetupKey">
</action>
<action name="dump2" class="org.jboss.soa.esb.actions.SystemPrintln">
<property name="message" value="After" />
<property name="printfull" value="true"/>
- </action>
+ </action>
+ <action name="AddProperty"
+ class="org.jboss.soa.esb.actions.PropertySetter">
+ <property name="jbesbfilename" value="BPMOrchestration3Test.log"/>
+ </action>
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
<action name="start_a_new_process_instance"
class="org.jboss.soa.esb.services.jbpm.actions.BpmProcessor">
<property name="command" value="StartProcessInstanceCommand" />
@@ -96,12 +105,6 @@
<object-path esb="contentsAsString" bpm="theData" />
</property>
</action>
- <!--
- <action name="dump3" class="org.jboss.soa.esb.actions.SystemPrintln">
- <property name="message" value="After" />
- <property name="printfull" value="true"/>
- </action>
- -->
</actions>
</service>
@@ -137,7 +140,8 @@
<property name="message" value="After" />
<property name="printfull" value="true"/>
</action>
- -->
+ -->
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
</actions>
</service>
@@ -164,6 +168,7 @@
<property name="ALERT_QUEUE_NAME" value="quickstart_bpm_orchestration3_service1_Alert" />
</action>
-->
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
</actions>
</service>
<service category="BPM_Orchestration3_Service2" name="Service2"
@@ -186,6 +191,7 @@
<property name="ALERT_QUEUE_NAME" value="quickstart_bpm_orchestration2_service2_Alert" />
</action>
-->
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
</actions>
</service>
<service category="BPM_Orchestration3_Service3" name="Service3"
@@ -208,6 +214,7 @@
<property name="ALERT_QUEUE_NAME" value="quickstart_bpm_orchestration2_service3_Alert" />
</action>
-->
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
</actions>
</service>
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/bpm_orchestration3/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration3/esb_actions/SimpleJMSNotifier.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/bpm_orchestration3/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration3/esb_actions/SimpleJMSNotifier.java 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/bpm_orchestration3/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration3/esb_actions/SimpleJMSNotifier.java 2007-11-26 04:09:17 UTC (rev 16799)
@@ -37,6 +37,8 @@
import javax.naming.Context;
import javax.naming.InitialContext;
+import org.jboss.soa.esb.actions.StoreMessageToFile;
+
public class SimpleJMSNotifier extends AbstractActionLifecycle {
protected ConfigTree _config;
private Logger logger = Logger.getLogger(SimpleJMSNotifier.class);
@@ -65,6 +67,7 @@
QueueSender send = session.createSender(que);
TextMessage tm = session.createTextMessage((String)message.getBody().get());
+ tm.setStringProperty(StoreMessageToFile.PROPERTY_JBESB_FILENAME, "BPMOrchestration3Test.log");
send.send(tm);
send.close();
@@ -80,4 +83,4 @@
queueName = _config.getAttribute("ALERT_QUEUE_NAME");
logger.info("Who to alert: " + queueName);
}
-}
\ No newline at end of file
+}
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/bpm_orchestration3/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration3/test/SendJMSMessage.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/bpm_orchestration3/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration3/test/SendJMSMessage.java 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/bpm_orchestration3/src/org/jboss/soa/esb/samples/quickstarts/bpm_orchestration3/test/SendJMSMessage.java 2007-11-26 04:09:17 UTC (rev 16799)
@@ -30,6 +30,8 @@
import javax.naming.InitialContext;
import javax.naming.NamingException;
+import org.jboss.soa.esb.actions.StoreMessageToFile;
+
public class SendJMSMessage {
QueueConnection conn;
QueueSession session;
@@ -49,21 +51,9 @@
public void stop() throws JMSException
{
- try {
- if(conn != null) {
- conn.stop();
- }
- } finally {
- try {
- if(session != null) {
- session.close();
- }
- } finally {
- if(conn != null) {
- conn.close();
- }
- }
- }
+ conn.stop();
+ session.close();
+ conn.close();
}
public void sendAMessage(String msg, String tokenID) throws JMSException {
@@ -72,28 +62,27 @@
ObjectMessage tm = session.createObjectMessage(msg);
if (tokenID != null && !tokenID.equals(""))
tm.setStringProperty("token",tokenID);
+ tm.setStringProperty(StoreMessageToFile.PROPERTY_JBESB_FILENAME, "BPMOrchestration3Test.log");
send.send(tm);
send.close();
}
public static void main(String args[]) throws Exception
- {
- SendJMSMessage sm = new SendJMSMessage();
- try {
- sm.setupConnection(args[0]);
- if (args.length < 3)
- sm.sendAMessage(args[1], null);
- else
- sm.sendAMessage(args[1], args[2]);
- } catch (Exception e) {
- System.out.println("\n**** Failed to send message to JMS Destination '" + args[0] + "'. " +
- "\n**** Your JMS Provider (e.g. your JBoss ESB/App Server) may not be running, or the JMS Destination may not be deployed." +
- "\n**** Exception: " + e.getMessage());
- } finally {
- sm.stop();
- }
-
+ {
+ SendJMSMessage sm = new SendJMSMessage();
+ try {
+ sm.setupConnection(args[0]);
+ if (args.length < 3)
+ sm.sendAMessage(args[1],null);
+ else
+ sm.sendAMessage(args[1],args[2]);
+ } catch (Exception e) {
+ System.out.println(e);
+ } finally {
+ sm.stop();
+ }
+
}
-}
\ No newline at end of file
+}
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/business_rules_service/jboss-esb.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/business_rules_service/jboss-esb.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/business_rules_service/jboss-esb.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -113,6 +113,7 @@
<object-path esb="body.customer" />
</property>
</action>
+
</actions>
</service>
<service category="ConciergeManager"
@@ -127,6 +128,7 @@
class="org.jboss.soa.esb.samples.quickstart.businessrules.ReviewMessage">
<property name="stuff" value="Concierge"/>
</action>
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
</actions>
</service>
@@ -142,6 +144,7 @@
class="org.jboss.soa.esb.samples.quickstart.businessrules.ReviewMessage">
<property name="stuff" value="Distribution"/>
</action>
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
</actions>
</service>
<service category="BasicShipping"
@@ -156,6 +159,7 @@
class="org.jboss.soa.esb.samples.quickstart.businessrules.ReviewMessage">
<property name="stuff" value="Shipping"/>
</action>
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
</actions>
</service>
</services>
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/business_rules_service/src/org/jboss/soa/esb/samples/quickstart/businessrules/test/SendJMSMessage.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/business_rules_service/src/org/jboss/soa/esb/samples/quickstart/businessrules/test/SendJMSMessage.java 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/business_rules_service/src/org/jboss/soa/esb/samples/quickstart/businessrules/test/SendJMSMessage.java 2007-11-26 04:09:17 UTC (rev 16799)
@@ -20,6 +20,7 @@
*/
package org.jboss.soa.esb.samples.quickstart.businessrules.test;
+import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.jms.JMSException;
@@ -33,7 +34,10 @@
import java.io.File;
import java.io.FileReader;
import java.io.IOException;
+import java.util.Properties;
+import org.jboss.soa.esb.actions.StoreMessageToFile;
+
public class SendJMSMessage {
QueueConnection conn;
QueueSession session;
@@ -42,7 +46,14 @@
public void setupConnection() throws JMSException, NamingException
{
- InitialContext iniCtx = new InitialContext();
+ Properties properties1 = new Properties();
+ properties1.put(Context.INITIAL_CONTEXT_FACTORY,
+ "org.jnp.interfaces.NamingContextFactory");
+ properties1.put(Context.URL_PKG_PREFIXES,
+ "org.jboss.naming:org.jnp.interfaces");
+ properties1.put(Context.PROVIDER_URL, "jnp://127.0.0.1:1099");
+ InitialContext iniCtx = new InitialContext(properties1);
+
Object tmp = iniCtx.lookup("ConnectionFactory");
QueueConnectionFactory qcf = (QueueConnectionFactory) tmp;
conn = qcf.createQueueConnection();
@@ -63,6 +74,7 @@
QueueSender send = session.createSender(que);
ObjectMessage tm = session.createObjectMessage(msg);
+ tm.setStringProperty(StoreMessageToFile.PROPERTY_JBESB_FILENAME, "BusinessRulesServiceTest.log");
send.send(tm);
send.close();
}
@@ -107,4 +119,4 @@
}
-}
\ No newline at end of file
+}
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/deadletter/jboss-esb.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/deadletter/jboss-esb.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/deadletter/jboss-esb.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -51,8 +51,13 @@
<!-- Send message to My Action -->
<action name="MyFailingAction" class="org.jboss.soa.esb.samples.quickstart.deadletter.MyFailingAsyncAction"/>
<action name="MyFailingSyncAction" class="org.jboss.soa.esb.samples.quickstart.deadletter.MyFailingSyncAction"/>
- </actions>
- </service>
+ <action name="action2" class="org.jboss.soa.esb.actions.SystemPrintln">
+ <property name="printfull" value="true"/>
+ </action>
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
+
+ </actions>
+ </service>
</services>
</jbossesb>
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/deadletter/src/org/jboss/soa/esb/samples/quickstart/deadletter/MyFailingAsyncAction.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/deadletter/src/org/jboss/soa/esb/samples/quickstart/deadletter/MyFailingAsyncAction.java 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/deadletter/src/org/jboss/soa/esb/samples/quickstart/deadletter/MyFailingAsyncAction.java 2007-11-26 04:09:17 UTC (rev 16799)
@@ -61,7 +61,8 @@
//the jbossesb.esb an by default it stores the message in the
//MessageStore under the DLQ categorization.
MessageStore ms = MessageStoreFactory.getInstance().getMessageStore();
-
+ Message rdlvrMessage = null;
+
try {
//empty out the DLQ
Map<URI, Message> messageMap = ms.getAllMessages(MessageStore.CLASSIFICATION_RDLVR);
@@ -84,7 +85,7 @@
rdlvrMessageMap = ms.getAllMessages(MessageStore.CLASSIFICATION_RDLVR);
}
for (URI key : rdlvrMessageMap.keySet()) {
- Message rdlvrMessage = rdlvrMessageMap.get(key);
+ rdlvrMessage = rdlvrMessageMap.get(key);
logger.info("*******************************");
logger.info("Message in the RDLVR should be the same message: " + message.getBody().toString().equals(rdlvrMessage.getBody().toString()));
logger.info("Message=" + message.getBody());
@@ -98,8 +99,8 @@
} catch (MessageDeliverException mde) {
throw new ActionProcessingException(mde.getMessage(), mde);
}
- return message;
+ return rdlvrMessage;
}
-}
\ No newline at end of file
+}
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/deadletter/src/org/jboss/soa/esb/samples/quickstart/deadletter/MyFailingSyncAction.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/deadletter/src/org/jboss/soa/esb/samples/quickstart/deadletter/MyFailingSyncAction.java 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/deadletter/src/org/jboss/soa/esb/samples/quickstart/deadletter/MyFailingSyncAction.java 2007-11-26 04:09:17 UTC (rev 16799)
@@ -63,7 +63,7 @@
//the jbossesb.esb an by default it stores the message in the
//MessageStore under the DLQ categorization.
MessageStore ms = MessageStoreFactory.getInstance().getMessageStore();
-
+ Message dlqMessage = null;
try {
//empty out the DLQ
Map<URI, Message> messageMap = ms.getAllMessages(MessageStore.CLASSIFICATION_DLQ);
@@ -90,7 +90,7 @@
messageMap = ms.getAllMessages(MessageStore.CLASSIFICATION_DLQ);
}
for (URI key : messageMap.keySet()) {
- Message dlqMessage = messageMap.get(key);
+ dlqMessage = messageMap.get(key);
logger.info("*******************************");
logger.info("Message in the DLQ queue should be the same message: " + message.getBody().toString().equals(dlqMessage.getBody().toString()));
logger.info("Message=" + message.getBody());
@@ -105,8 +105,8 @@
} catch (FaultMessageException fme) {
throw new ActionProcessingException(fme.getMessage(), fme);
}
- return message;
+ return dlqMessage;
}
-}
\ No newline at end of file
+}
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/deadletter/src/org/jboss/soa/esb/samples/quickstart/deadletter/test/SendJMSMessage.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/deadletter/src/org/jboss/soa/esb/samples/quickstart/deadletter/test/SendJMSMessage.java 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/deadletter/src/org/jboss/soa/esb/samples/quickstart/deadletter/test/SendJMSMessage.java 2007-11-26 04:09:17 UTC (rev 16799)
@@ -21,6 +21,7 @@
package org.jboss.soa.esb.samples.quickstart.deadletter.test;
import java.util.Date;
+import java.util.Properties;
import javax.jms.JMSException;
import javax.jms.ObjectMessage;
@@ -29,6 +30,7 @@
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
+import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
@@ -42,7 +44,14 @@
public void setupConnection() throws JMSException, NamingException
{
- InitialContext iniCtx = new InitialContext();
+ Properties properties1 = new Properties();
+ properties1.put(Context.INITIAL_CONTEXT_FACTORY,
+ "org.jnp.interfaces.NamingContextFactory");
+ properties1.put(Context.URL_PKG_PREFIXES,
+ "org.jboss.naming:org.jnp.interfaces");
+ properties1.put(Context.PROVIDER_URL, "jnp://127.0.0.1:1099");
+
+ InitialContext iniCtx = new InitialContext(properties1);
Object tmp = iniCtx.lookup("ConnectionFactory");
QueueConnectionFactory qcf = (QueueConnectionFactory) tmp;
conn = qcf.createQueueConnection();
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/exceptions_faults/build.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/exceptions_faults/build.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/exceptions_faults/build.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -12,7 +12,7 @@
<echo>Runs Test JMS Sender</echo>
<java fork="yes" classname="org.jboss.soa.esb.samples.quickstart.exceptions.test.SendJMSMessage" failonerror="true">
<arg value="queue/quickstart_exceptions_faults_GW"/>
- <arg value="LostMessageService"/>
+ <arg value="ExceptionCaughtService"/>
<arg value="Via Gateway"/>
<classpath refid="exec-classpath"/>
</java>
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/exceptions_faults/jboss-esb.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/exceptions_faults/jboss-esb.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/exceptions_faults/jboss-esb.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -66,6 +66,10 @@
<action name="Final Good Action" class="org.jboss.soa.esb.samples.quickstart.exceptions.JustAnotherAction"
process="displayMessage" >
</action>
+ <action name="AddProperty" class="org.jboss.soa.esb.actions.PropertySetter>
+ <property name="jbesbfilename" value="ExceptionsFaultsTest.log"/>
+ </action>
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
</actions>
</service>
@@ -96,12 +100,10 @@
<property name="exceptionMethod" value="catchesException" />
</action>
<action name="Bad Action" class="org.jboss.soa.esb.samples.quickstart.exceptions.MyBasicAction"
- process="causesException" >
- </action>
+ process="causesException"/>
<action name="Never Reached" class="org.jboss.soa.esb.samples.quickstart.exceptions.MyBasicAction"
- process="displayMessage" >
- </action>
-
+ process="displayMessage"/>
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
</actions>
</service>
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/fun_cbr/jboss-esb.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/fun_cbr/jboss-esb.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/fun_cbr/jboss-esb.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -45,6 +45,7 @@
</jms-listener>
</listeners>
<actions mep="OneWay">
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
<action class="org.jboss.soa.esb.actions.ContentBasedRouter" name="ContentBasedRouter">
<property name="ruleSet" value="FunCBRRules-XPath.drl"/>
<property name="ruleLanguage" value="XPathLanguage.dsl"/>
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/fun_cbr/src/org/jboss/soa/esb/samples/quickstart/funcbr/test/SendJMSMessage.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/fun_cbr/src/org/jboss/soa/esb/samples/quickstart/funcbr/test/SendJMSMessage.java 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/fun_cbr/src/org/jboss/soa/esb/samples/quickstart/funcbr/test/SendJMSMessage.java 2007-11-26 04:09:17 UTC (rev 16799)
@@ -29,11 +29,16 @@
import javax.jms.QueueSession;
import javax.jms.QueueSender;
import javax.jms.ObjectMessage;
+import javax.naming.Context;
+import javax.naming.InitialContext;
+import javax.naming.NamingException;
import java.io.File;
import java.io.FileReader;
import java.io.IOException;
+import java.util.Properties;
+
public class SendJMSMessage {
QueueConnection conn;
QueueSession session;
@@ -42,7 +47,14 @@
public void setupConnection() throws JMSException, NamingException
{
- InitialContext iniCtx = new InitialContext();
+ Properties properties1 = new Properties();
+ properties1.put(Context.INITIAL_CONTEXT_FACTORY,
+ "org.jnp.interfaces.NamingContextFactory");
+ properties1.put(Context.URL_PKG_PREFIXES,
+ "org.jboss.naming:org.jnp.interfaces");
+ properties1.put(Context.PROVIDER_URL, "jnp://127.0.0.1:1099");
+ InitialContext iniCtx = new InitialContext(properties1);
+
Object tmp = iniCtx.lookup("ConnectionFactory");
QueueConnectionFactory qcf = (QueueConnectionFactory) tmp;
conn = qcf.createQueueConnection();
@@ -60,12 +72,13 @@
}
public void sendAMessage(String msg) throws JMSException {
-
QueueSender send = session.createSender(que);
ObjectMessage tm = session.createObjectMessage(msg);
+ tm.setStringProperty("jbesbfilename", "FunCBRTest.log");
send.send(tm);
send.close();
}
+
public String readAsciiFile(String fileName) throws IOException {
FileReader fr = null;
char[] thechars = null;
@@ -107,4 +120,4 @@
}
-}
\ No newline at end of file
+}
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/groovy_gateway/jboss-esb.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/groovy_gateway/jboss-esb.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/groovy_gateway/jboss-esb.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -30,6 +30,8 @@
<actions mep="RequestResponse">
<action name="greeting1" class="org.jboss.soa.esb.samples.quickstart.groovygateway.GreeterAction"/>
<action name="greeting2" class="org.jboss.soa.esb.samples.quickstart.groovygateway.AnotherAction"/>
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
+
</actions>
</service>
</services>
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/helloworld_action/jboss-esb.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/helloworld_action/jboss-esb.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/helloworld_action/jboss-esb.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -65,7 +65,8 @@
</target>
</NotificationList>
</property>
- </action>
+ </action>
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
</actions>
</service>
</services>
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/helloworld_action/src/org/jboss/soa/esb/samples/quickstart/helloworldaction/test/SendJMSMessage.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/helloworld_action/src/org/jboss/soa/esb/samples/quickstart/helloworldaction/test/SendJMSMessage.java 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/helloworld_action/src/org/jboss/soa/esb/samples/quickstart/helloworldaction/test/SendJMSMessage.java 2007-11-26 04:09:17 UTC (rev 16799)
@@ -30,6 +30,8 @@
import javax.naming.InitialContext;
import javax.naming.NamingException;
+import org.jboss.soa.esb.actions.StoreMessageToFile;
+
public class SendJMSMessage {
QueueConnection conn;
QueueSession session;
@@ -59,6 +61,7 @@
QueueSender send = session.createSender(que);
ObjectMessage tm = session.createObjectMessage(msg);
+ tm.setStringProperty(StoreMessageToFile.PROPERTY_JBESB_FILENAME, "HelloWorldActionTest.log");
send.send(tm);
send.close();
}
@@ -73,4 +76,4 @@
}
-}
\ No newline at end of file
+}
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/helloworld_file_notifier/build.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/helloworld_file_notifier/build.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/helloworld_file_notifier/build.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -1,4 +1,6 @@
<project name="Quickstart_helloworld_file_notifier" default="run" basedir=".">
+
+ <property environment="env" />
<description>
${ant.project.name}
@@ -10,10 +12,12 @@
<target name="config">
<property name="results.dir" location="."/>
+ <echoproperties/>
<copy file="jboss-esb-unfiltered.xml"
tofile="jboss-esb.xml" overwrite="true">
<filterset>
<filter token="results.dir" value="file:///${results.dir}"/>
+ <filter token="tmp.dir" value="${java.io.tmpdir}"/>
</filterset>
</copy>
</target>
@@ -30,7 +34,7 @@
<target name="sendesb" depends="compile"
description="Will send an esb Message">
<echo>Runs Test ESB Message Sender</echo>
- <java fork="yes" classname="org.jboss.soa.esb.samples.quickstart.helloworldfilenotifier.test.SendEsbMessage" failonerror="true">
+ <java fork="yes" classname="org.jboss.soa.esb.samples.quickstart.helloworld.test.SendEsbMessage" failonerror="true">
<arg value="FirstServiceESB"/> <!-- service category -->
<arg value="SimpleListener"/> <!-- service name -->
<arg value="Hello World - Straight to ESB listener - no Gateway"/> <!-- Message text -->
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/helloworld_file_notifier/jboss-esb-unfiltered.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/helloworld_file_notifier/jboss-esb-unfiltered.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/helloworld_file_notifier/jboss-esb-unfiltered.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -54,7 +54,7 @@
maxThreads="1"
/>
</listeners>
- <actions mep="OneWay">
+ <actions>
<action name="routeAction" class="org.jboss.soa.esb.actions.StaticRouter">
<property name="destinations">
<route-to service-category="routerToDisplay" service-name="DisplayRouterListener" />
@@ -98,6 +98,7 @@
<target class="NotifyConsole"/>
<target class="NotifyFiles">
<file append="false" URI="@results.dir@/results.log"/>
+ <file append="false" URI="@tmp.dir@/HelloWorldFileNotifierTest.log"/>
</target>
</NotificationList>
<NotificationList type="err">
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/jms_topic/build.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/jms_topic/build.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/jms_topic/build.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -9,10 +9,8 @@
<import file="../conf/base-build.xml"/>
<target name="runtest" depends="compile" description="Send a message to the JMS Topic">
- <java fork="yes" classname="org.jboss.soa.esb.testutils.JMSUtil" failonerror="true"
+ <java fork="yes" classname="org.jboss.soa.esb.samples.quickstart.jmstopic.SendJMSMessage" failonerror="true"
classpathref="exec-classpath">
- <arg value="quickstart_jmstopic_topic"/>
- <arg value="topic"/>
<arg value="Hello"/>
</java>
</target>
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/jms_topic/jboss-esb.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/jms_topic/jboss-esb.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/jms_topic/jboss-esb.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -72,6 +72,11 @@
</listeners>
<actions mep="OneWay">
<action name="target" class="org.jboss.soa.esb.samples.quickstart.jmstopic.TargetServiceAction" />
+ <action name="AddProperty"
+ class="org.jboss.soa.esb.actions.PropertySetter">
+ <property name="jbesbfilename" value="JMSTopicTest.log"/>
+ </action>
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
</actions>
</service>
Added: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/jms_topic/src/org/jboss/soa/esb/samples/quickstart/jmstopic/SendJMSMessage.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/jms_topic/src/org/jboss/soa/esb/samples/quickstart/jmstopic/SendJMSMessage.java (rev 0)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/jms_topic/src/org/jboss/soa/esb/samples/quickstart/jmstopic/SendJMSMessage.java 2007-11-26 04:09:17 UTC (rev 16799)
@@ -0,0 +1,84 @@
+/*
+ * 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 JBoss Inc.
+ */
+package org.jboss.soa.esb.samples.quickstart.jmstopic;
+
+import java.util.Properties;
+
+import javax.jms.JMSException;
+import javax.jms.ObjectMessage;
+
+import javax.jms.Topic;
+import javax.jms.TopicConnection;
+import javax.jms.TopicConnectionFactory;
+import javax.jms.TopicPublisher;
+import javax.jms.TopicSubscriber;
+import javax.jms.TopicSession;
+
+import javax.naming.Context;
+import javax.naming.InitialContext;
+import javax.naming.NamingException;
+
+public class SendJMSMessage {
+ TopicConnectionFactory tcf;
+ TopicSession session;
+ Topic topic;
+ TopicConnection tc;
+
+ public void setupConnection() throws JMSException, NamingException
+ {
+ Properties properties1 = new Properties();
+ properties1.put(Context.INITIAL_CONTEXT_FACTORY,
+ "org.jnp.interfaces.NamingContextFactory");
+ properties1.put(Context.URL_PKG_PREFIXES,
+ "org.jboss.naming:org.jnp.interfaces");
+ properties1.put(Context.PROVIDER_URL, "jnp://127.0.0.1:1099");
+ InitialContext iniCtx = new InitialContext(properties1);
+
+ tcf = (TopicConnectionFactory) iniCtx.lookup("ConnectionFactory");
+ topic = (Topic) iniCtx.lookup("/topic/quickstart_jmstopic_topic");
+ }
+
+ public void stop() throws JMSException
+ {
+ tc.close();
+ session.close();
+ tc.close();
+ }
+
+ public void sendAMessage(String msg) throws JMSException {
+ tc = tcf.createTopicConnection();
+ session = tc.createTopicSession(false, TopicSession.AUTO_ACKNOWLEDGE);
+ TopicPublisher tp = session.createPublisher(topic);
+ ObjectMessage tm = session.createObjectMessage(msg);
+ tp.publish(tm);
+ }
+
+
+ public static void main(String args[]) throws Exception
+ {
+ SendJMSMessage sm = new SendJMSMessage();
+ sm.setupConnection();
+ sm.sendAMessage(args[0]);
+ sm.stop();
+
+ }
+
+}
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/load_generator/build.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/load_generator/build.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/load_generator/build.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -5,48 +5,49 @@
${line.separator}
</description>
+ <property environment="env"/>
+
<!-- Import the base Ant build script... -->
<import file="../conf/base-build.xml" />
+ <property file="${product.dir}/install/deployment.properties" />
- <target name="init-groovy" depends="dependencies">
- <path id="groovy.classpath">
- <fileset dir="${org.jboss.esb.server.home}/server/${org.jboss.esb.server.config}/deploy">
- <include name="jboss-aop-jdk50**/*.jar"/>
- </fileset>
- <fileset dir="${org.jboss.esb.server.home}/server/${org.jboss.esb.server.config}/lib" includes="*.jar"/>
- <fileset dir="${org.jboss.esb.server.home}/server/${org.jboss.esb.server.config}/deploy/jbossesb.sar/lib" includes="*.jar" />
- <fileset dir="${org.jboss.esb.server.home}/server/${org.jboss.esb.server.config}/deploy/jbossesb.sar/lib" includes="commons-*.jar" />
- <fileset dir="${org.jboss.esb.server.home}/client" includes="jbossall-client.jar" />
- <fileset dir="${org.jboss.esb.server.home}/lib/endorsed" includes="xercesImpl.jar" />
- </path>
+ <path id="groovy.classpath">
+ <fileset dir="${org.jboss.esb.server.home}/server/${org.jboss.esb.server.config}/deploy">
+ <include name="jboss-aop-jdk50**/*.jar"/>
+ </fileset>
+ <fileset dir="${org.jboss.esb.server.home}/server/${org.jboss.esb.server.config}/lib" includes="*.jar"/>
+ <fileset dir="${org.jboss.esb.server.home}/server/${org.jboss.esb.server.config}/deploy/jbossesb.sar/lib" includes="*.jar" />
+ <fileset dir="${org.jboss.esb.server.home}/server/${org.jboss.esb.server.config}/deploy/jbossesb.sar/lib" includes="commons-*.jar" />
+ <fileset dir="${org.jboss.esb.server.home}/client" includes="jbossall-client.jar" />
+ <fileset dir="${org.jboss.esb.server.home}/lib/endorsed" includes="xercesImpl.jar" />
+ </path>
- <taskdef name="groovyc" classname="org.codehaus.groovy.ant.Groovyc" classpathref="groovy.classpath" />
- </target>
+ <taskdef name="groovyc" classname="org.codehaus.groovy.ant.Groovyc" classpathref="groovy.classpath" />
- <target name="compile-churn" depends="compile, init-groovy" description="compile groovy to bytecode">
- <mkdir dir="load_generator_classes" />
- <copy todir="load_generator_classes" overwrite="true">
+ <target name="compile-churn" depends="compile" description="compile groovy to bytecode">
+ <mkdir dir="${basedir}/build/classes" />
+ <copy todir="${basedir}/build/classes" overwrite="true">
<fileset dir="${basedir}/scripts/">
<include name="*.xml" />
<include name="*.properties" />
</fileset>
</copy>
- <groovyc destdir="load_generator_classes" srcdir="${basedir}/scripts" includes="*.groovy" classpathref="groovy.classpath" />
+ <groovyc destdir="build/classes" srcdir="${basedir}/scripts" includes="*.groovy" classpathref="groovy.classpath" />
</target>
<target name="load-agent" depends="compile-churn" description="Test the load agent script/settings">
<java classname="JmsLoadAgent" >
<classpath refid="groovy.classpath" />
- <classpath location="load_generator_classes" />
- <arg value="load_generator_classes/load.xml" />
+ <classpath location="${basedir}/build/classes" />
+ <arg value="${basedir}/build/classes/load.xml" />
</java>
</target>
<target name="load-report" depends="compile-churn" description="Test the report agent script/settings">
<java classname="LoadReport">
<classpath refid="groovy.classpath" />
- <classpath location="load_generator_classes" />
- <arg value="load_generator_classes/load.xml" />
+ <classpath location="${basedir}/build/classes" />
+ <arg value="${basedir}/build/classes/load.xml" />
</java>
</target>
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/load_generator/jboss-esb.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/load_generator/jboss-esb.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/load_generator/jboss-esb.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -59,6 +59,7 @@
class="org.jboss.soa.esb.actions.SystemPrintln">
<property name="printfull" value="true" />
</action>
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
</actions>
</service>
</services>
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/load_generator/scripts/JmsLoadAgent.groovy
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/load_generator/scripts/JmsLoadAgent.groovy 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/load_generator/scripts/JmsLoadAgent.groovy 2007-11-26 04:09:17 UTC (rev 16799)
@@ -29,6 +29,8 @@
import javax.naming.InitialContext
import javax.naming.NamingException
+import org.jboss.soa.esb.actions.StoreMessageToFile
+
/**
* Simple Groovy load script that will simulate load for a JMS gateway based ESB service call.
*
@@ -124,6 +126,7 @@
QueueSender send = session.createSender(que)
ObjectMessage tm = session.createObjectMessage(new File(agentBean.payload).text)
+ tm.setStringProperty(StoreMessageToFile.PROPERTY_JBESB_FILENAME, "LoadGeneratorTest.log");
1.upto(agentBean.msgCount)
{
send.send(tm)
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/messagefilter/jboss-esb.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/messagefilter/jboss-esb.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/messagefilter/jboss-esb.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -70,12 +70,17 @@
<action name="notificationAction" class="org.jboss.soa.esb.actions.Notifier">
<property name="okMethod" value="notifyOK" />
<property name="notification-details">
- <NotificationList type="OK">
- <target class="NotifyConsole" />
- </NotificationList>
- </property>
- </action>
- </actions>
+ <NotificationList type="OK">
+ <target class="NotifyConsole" />
+ </NotificationList>
+ </property>
+ </action>
+ <action name="AddProperty"
+ class="org.jboss.soa.esb.actions.PropertySetter">
+ <property name="jbesbfilename" value="MessageFilterTest.log"/>
+ </action>
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
+ </actions>
</service>
</services>
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/messagefilter/src/org/jboss/soa/esb/samples/quickstart/messagefilter/test/SendJMSMessage.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/messagefilter/src/org/jboss/soa/esb/samples/quickstart/messagefilter/test/SendJMSMessage.java 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/messagefilter/src/org/jboss/soa/esb/samples/quickstart/messagefilter/test/SendJMSMessage.java 2007-11-26 04:09:17 UTC (rev 16799)
@@ -32,6 +32,8 @@
import javax.naming.InitialContext;
import javax.naming.NamingException;
+import org.jboss.soa.esb.actions.StoreMessageToFile;
+
import org.jboss.soa.esb.samples.quickstart.messagefilter.Order;
public class SendJMSMessage {
@@ -63,6 +65,7 @@
QueueSender send = session.createSender(que);
ObjectMessage tm = session.createObjectMessage(msg);
+ tm.setStringProperty(StoreMessageToFile.PROPERTY_JBESB_FILENAME, "MessageFilterTest.log");
send.send(tm);
send.close();
}
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/messagestore/jboss-esb.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/messagestore/jboss-esb.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/messagestore/jboss-esb.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -47,7 +47,12 @@
<target class="NotifyConsole" />
</NotificationList>
</property>
- </action>
+ </action>
+ <action name="AddProperty"
+ class="org.jboss.soa.esb.actions.PropertySetter">
+ <property name="jbesbfilename" value="MessageStoreTest.log"/>
+ </action>
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
<!-- Check that the message is really there (executes on success of pipeline) -->
<action name="CheckMessageStore" class="org.jboss.soa.esb.samples.quickstart.messagestore.CheckMessageStoreAction" />
<!-- Add a copy of the message to the message store under categorization 'test' -->
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/scheduled_services/jboss-esb.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/scheduled_services/jboss-esb.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/scheduled_services/jboss-esb.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -28,6 +28,8 @@
<action name="groovy" class="org.jboss.soa.esb.actions.scripting.GroovyActionProcessor">
<property name="script" value="/scripts/iTunesTop5.groovy" />
</action>
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
+
</actions>
</service>
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/scheduled_services/src/org/jboss/soa/esb/samples/quickstart/scheduler/MyScheduledActionMsgComposer.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/scheduled_services/src/org/jboss/soa/esb/samples/quickstart/scheduler/MyScheduledActionMsgComposer.java 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/scheduled_services/src/org/jboss/soa/esb/samples/quickstart/scheduler/MyScheduledActionMsgComposer.java 2007-11-26 04:09:17 UTC (rev 16799)
@@ -28,6 +28,8 @@
import org.jboss.soa.esb.message.format.MessageType;
import org.jboss.soa.esb.schedule.SchedulingException;
+import org.jboss.soa.esb.actions.StoreMessageToFile;
+
public class MyScheduledActionMsgComposer implements ScheduledEventMessageComposer {
public void initialize(ConfigTree config) throws ConfigurationException {
System.out.println("** initialize: " + config);
@@ -41,6 +43,7 @@
System.out.println("compose a message");
Message myMessage = MessageFactory.getInstance().getMessage(MessageType.JBOSS_XML);
myMessage.getBody().add("Hello Scheduled World");
+ myMessage.getProperties().setProperty(StoreMessageToFile.PROPERTY_JBESB_FILENAME, "ScheduledServices.log");
return myMessage;
}
@@ -48,4 +51,4 @@
System.out.println("onProcessingComplete");
return message;
}
-}
\ No newline at end of file
+}
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/scheduled_services/src/org/jboss/soa/esb/samples/quickstart/scheduler/test/SendEsbMessage.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/scheduled_services/src/org/jboss/soa/esb/samples/quickstart/scheduler/test/SendEsbMessage.java 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/scheduled_services/src/org/jboss/soa/esb/samples/quickstart/scheduler/test/SendEsbMessage.java 2007-11-26 04:09:17 UTC (rev 16799)
@@ -35,9 +35,25 @@
*/
public class SendEsbMessage
{
+ public SendEsbMessage() {
+ }
+
+ public void sendMessage(String category, String serviceName, String msgText) {
+ System.out.println("Inbound Data: " + msgText);
+ try {
+ ServiceInvoker invoker = new ServiceInvoker(category,serviceName);
+ Message requestMessage;
+ requestMessage = MessageFactory.getInstance().getMessage(MessageType.JBOSS_XML);
+ requestMessage.getBody().add(msgText);
+ invoker.deliverAsync(requestMessage); // no waiting for a response
+ } catch (Exception e) {
+ System.out.println("Exception caught by client: " + e);
+ }
+ }
+
public static void main(String args[]) throws Exception
{
-// Setting the ConnectionFactory such that it will use scout
+ // Setting the ConnectionFactory such that it will use scout
System.setProperty("javax.xml.registry.ConnectionFactoryClass","org.apache.ws.scout.registry.ConnectionFactoryImpl");
@@ -55,17 +71,8 @@
if (args[2] != null && !args[2].equals(""))
msgText = args[2];
- System.out.println("Inbound Data: " + msgText);
-
- ServiceInvoker invoker = new ServiceInvoker(category,serviceName);
- Message requestMessage;
- requestMessage = MessageFactory.getInstance().getMessage(MessageType.JBOSS_XML);
- requestMessage.getBody().add(msgText);
- try {
- invoker.deliverAsync(requestMessage); // no waiting for a response
- } catch (Exception e) {
- System.out.println("Exception caught by client: " + e);
- }
+ SendEsbMessage sem = new SendEsbMessage();
+ sem.sendMessage(category, serviceName, msgText);
}
}
\ No newline at end of file
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/simple_cbr/jboss-esb.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/simple_cbr/jboss-esb.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/simple_cbr/jboss-esb.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -54,6 +54,7 @@
</jms-listener>
</listeners>
<actions mep="OneWay">
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
<action class="org.jboss.soa.esb.actions.ContentBasedRouter" name="ContentBasedRouter">
<property name="ruleSet" value="SimpleCBRRules-XPath.drl"/>
<property name="ruleLanguage" value="XPathLanguage.dsl"/>
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/simple_cbr/src/org/jboss/soa/esb/samples/quickstart/simplecbr/test/SendJMSMessage.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/simple_cbr/src/org/jboss/soa/esb/samples/quickstart/simplecbr/test/SendJMSMessage.java 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/simple_cbr/src/org/jboss/soa/esb/samples/quickstart/simplecbr/test/SendJMSMessage.java 2007-11-26 04:09:17 UTC (rev 16799)
@@ -63,6 +63,7 @@
QueueSender send = session.createSender(que);
ObjectMessage tm = session.createObjectMessage(msg);
+ tm.setStringProperty("jbesbfilename", "SimpleCBRTest.log");
send.send(tm);
send.close();
}
@@ -107,4 +108,4 @@
}
-}
\ No newline at end of file
+}
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/spring_aop/jboss-esb.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/spring_aop/jboss-esb.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/spring_aop/jboss-esb.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -42,7 +42,8 @@
process="sayHelloAopStyle">
<property name="exceptionMethod" value="exceptionHandler"/>
<property name="springContextXml" value="spring-context.xml"/>
- </action>
+ </action>
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
</actions>
</service>
</services>
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/spring_aop/src/org/jboss/soa/esb/samples/quickstart/spring_aop/MySpringEnabledAction.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/spring_aop/src/org/jboss/soa/esb/samples/quickstart/spring_aop/MySpringEnabledAction.java 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/spring_aop/src/org/jboss/soa/esb/samples/quickstart/spring_aop/MySpringEnabledAction.java 2007-11-26 04:09:17 UTC (rev 16799)
@@ -49,7 +49,9 @@
logHeader();
// interceptor will get applied here
// check the console output to see the interceptor changed the message
- hello.setGreeting((String)message.getBody().get());
+ String helloString = (String) message.getBody().get();
+ hello.setGreeting(helloString);
+ message.getBody().add(hello.getGreeting());
logFooter();
return message;
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/spring_aop/src/org/jboss/soa/esb/samples/quickstart/spring_aop/test/SendJMSMessage.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/spring_aop/src/org/jboss/soa/esb/samples/quickstart/spring_aop/test/SendJMSMessage.java 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/spring_aop/src/org/jboss/soa/esb/samples/quickstart/spring_aop/test/SendJMSMessage.java 2007-11-26 04:09:17 UTC (rev 16799)
@@ -30,6 +30,8 @@
import javax.naming.InitialContext;
import javax.naming.NamingException;
+import org.jboss.soa.esb.actions.StoreMessageToFile;
+
/**
* Send a JMS message that the ESB will listen for.
*
@@ -67,6 +69,7 @@
{
QueueSender send = session.createSender(que);
ObjectMessage tm = session.createObjectMessage(msg);
+ tm.setStringProperty(StoreMessageToFile.PROPERTY_JBESB_FILENAME, "SpringAOPTest.log");
send.send(tm);
send.close();
}
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/spring_helloworld/jboss-esb.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/spring_helloworld/jboss-esb.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/spring_helloworld/jboss-esb.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -49,12 +49,13 @@
<property name="exceptionMethod" value="exceptionHandler"/>
<property name="springContextXml" value="spring-context-goodbye.xml"/>
</action>
- <action name="addHelloGoodbye"
+ <action name="addHelloGoodbye"
class="org.jboss.soa.esb.samples.quickstart.spring_helloworld.MySpringEnabledAction"
process="sayHelloSpring,sayGoodbyeSpring,displayMessage">
<property name="exceptionMethod" value="exceptionHandler"/>
<property name="springContextXml" value="spring-context-goodbye.xml,spring-context-hello.xml"/>
- </action>
+ </action>
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
</actions>
</service>
</services>
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/spring_helloworld/src/org/jboss/soa/esb/samples/quickstart/spring_helloworld/test/SendJMSMessage.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/spring_helloworld/src/org/jboss/soa/esb/samples/quickstart/spring_helloworld/test/SendJMSMessage.java 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/spring_helloworld/src/org/jboss/soa/esb/samples/quickstart/spring_helloworld/test/SendJMSMessage.java 2007-11-26 04:09:17 UTC (rev 16799)
@@ -30,6 +30,8 @@
import javax.naming.InitialContext;
import javax.naming.NamingException;
+import org.jboss.soa.esb.actions.StoreMessageToFile;
+
/**
* Send a JMS message that the ESB will listen for.
*
@@ -66,6 +68,7 @@
QueueSender send = session.createSender(que);
ObjectMessage tm = session.createObjectMessage(msg);
+ tm.setStringProperty(StoreMessageToFile.PROPERTY_JBESB_FILENAME, "SpringHelloWorldTest.log");
send.send(tm);
send.close();
}
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/spring_jpetstore/jboss-esb.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/spring_jpetstore/jboss-esb.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/spring_jpetstore/jboss-esb.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -37,12 +37,13 @@
/>
</listeners>
<actions>
- <action name="insertOrderAction"
+ <action name="insertOrderAction"
class="org.jboss.soa.esb.samples.quickstart.spring_jpetstore.InsertOrderAction"
process="insertOrder">
<property name="exceptionMethod" value="exceptionHandler"/>
<property name="springContextXml" value="applicationContext.xml,dataAccessContext-local.xml"/>
- </action>
+ </action>
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
</actions>
</service>
</services>
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/spring_jpetstore/src/org/jboss/soa/esb/samples/quickstart/spring_jpetstore/test/SendJMSMessage.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/spring_jpetstore/src/org/jboss/soa/esb/samples/quickstart/spring_jpetstore/test/SendJMSMessage.java 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/spring_jpetstore/src/org/jboss/soa/esb/samples/quickstart/spring_jpetstore/test/SendJMSMessage.java 2007-11-26 04:09:17 UTC (rev 16799)
@@ -34,6 +34,8 @@
import javax.naming.InitialContext;
import javax.naming.NamingException;
+import org.jboss.soa.esb.actions.StoreMessageToFile;
+
/**
* Send a JMS message that the ESB will listen for.
*
@@ -70,6 +72,7 @@
QueueSender send = session.createSender(que);
ObjectMessage tm = session.createObjectMessage(msg);
+ tm.setStringProperty(StoreMessageToFile.PROPERTY_JBESB_FILENAME, "SpringJPetStoreTest.log");
send.send(tm);
send.close();
}
@@ -114,4 +117,4 @@
sm.stop();
}
-}
\ No newline at end of file
+}
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_consumer1/build.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_consumer1/build.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_consumer1/build.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -47,6 +47,15 @@
<delete verbose="true" quiet="true"
file="${org.jboss.esb.server.deploy.dir}/${ant.project.name}.war"/>
</target>
+
+ <target name="sendjms" depends="compile">
+ <echo>Send ESB message that triggers webservice call</echo>
+ <java fork="yes" classname="org.jboss.soa.esb.samples.quickstart.webservice_consumer1.test.SendJMSMessage" failonerror="true">
+ <arg value="Jimbo"/>
+ <classpath refid="exec-classpath"/>
+ </java>
+
+ </target>
<target name="runtest" depends="compile">
<echo>Send ESB message that triggers webservice call</echo>
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_consumer1/jboss-esb.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_consumer1/jboss-esb.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_consumer1/jboss-esb.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -37,6 +37,11 @@
<action name="response-mapper"
class="org.jboss.soa.esb.samples.quickstart.webservice_consumer1.MyResponseAction">
</action>
+ <action name="AddProperty"
+ class="org.jboss.soa.esb.actions.PropertySetter">
+ <property name="jbesbfilename" value="WebServiceConsumer1Test.log"/>
+ </action>
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
</actions>
</service>
</services>
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_consumer1/src/org/jboss/soa/esb/samples/quickstart/webservice_consumer1/test/SendEsbMessage.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_consumer1/src/org/jboss/soa/esb/samples/quickstart/webservice_consumer1/test/SendEsbMessage.java 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_consumer1/src/org/jboss/soa/esb/samples/quickstart/webservice_consumer1/test/SendEsbMessage.java 2007-11-26 04:09:17 UTC (rev 16799)
@@ -26,13 +26,15 @@
import org.jboss.soa.esb.message.format.MessageFactory;
import org.jboss.soa.esb.message.format.MessageType;
+import org.jboss.soa.esb.actions.StoreMessageToFile;
+
public class SendEsbMessage
{
/*
* Send a message directly the the ESB internal JMS listener. Demonstrates
* how one can bypass the gateway and speak directly to an ESB service.
*/
- private void sendMessage(String message) throws Exception
+ public void sendMessage(String message) throws Exception
{
// Create the delivery adapter for the target service (cache it)
System.setProperty("javax.xml.registry.ConnectionFactoryClass",
@@ -48,6 +50,7 @@
MessageType.JBOSS_XML);
requestMessage.getBody().add(message);
+ requestMessage.getProperties().setProperty(StoreMessageToFile.PROPERTY_JBESB_FILENAME, "WebServicesConsumer1Test.log");
// Deliver the request message synchronously - timeout after 20
// seconds...
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_consumer2/build.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_consumer2/build.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_consumer2/build.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -48,6 +48,16 @@
<delete verbose="true" quiet="true"
file="${org.jboss.esb.server.deploy.dir}/${ant.project.name}.war"/>
</target>
+
+ <target name="sendjms" depends="compile">
+
+ <echo>Send ESB message that triggers webservice call</echo>
+ <java fork="yes" classname="org.jboss.soa.esb.samples.quickstart.webservice_consumer2.test.SendJMSMessage" failonerror="true">
+ <arg value="Jimbo"/>
+ <classpath refid="exec-classpath"/>
+ </java>
+ </target>
+
<target name="runtest" depends="compile">
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_consumer2/jboss-esb.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_consumer2/jboss-esb.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_consumer2/jboss-esb.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -36,7 +36,12 @@
</action>
<action name="response-mapper"
class="org.jboss.soa.esb.samples.quickstart.webservice_consumer2.MyResponseAction">
- </action>
+ </action>
+ <action name="AddProperty"
+ class="org.jboss.soa.esb.actions.PropertySetter">
+ <property name="jbesbfilename" value="BPMOrchestration2Test.log"/>
+ </action>
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
</actions>
</service>
</services>
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_consumer2/src/org/jboss/soa/esb/samples/quickstart/webservice_consumer2/test/SendEsbMessage.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_consumer2/src/org/jboss/soa/esb/samples/quickstart/webservice_consumer2/test/SendEsbMessage.java 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_consumer2/src/org/jboss/soa/esb/samples/quickstart/webservice_consumer2/test/SendEsbMessage.java 2007-11-26 04:09:17 UTC (rev 16799)
@@ -25,6 +25,7 @@
import org.jboss.soa.esb.message.format.MessageFactory;
import org.jboss.soa.esb.message.format.MessageType;
+import org.jboss.soa.esb.actions.StoreMessageToFile;
public class SendEsbMessage
{
@@ -59,4 +60,4 @@
SendEsbMessage sm = new SendEsbMessage();
sm.sendMessage();
}
-}
\ No newline at end of file
+}
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_mtom/jboss-esb.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_mtom/jboss-esb.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_mtom/jboss-esb.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -39,6 +39,11 @@
<property name="message"
value="[Quickstart_webservice_producer] Message after invoking jbossws endpoint"/>
</action>
+ <action name="AddProperty"
+ class="org.jboss.soa.esb.actions.PropertySetter">
+ <property name="jbesbfilename" value="WebServiceMTOMTest.log"/>
+ </action>
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
</actions>
</service>
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_producer/jboss-esb.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_producer/jboss-esb.xml 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_producer/jboss-esb.xml 2007-11-26 04:09:17 UTC (rev 16799)
@@ -37,7 +37,7 @@
<jms-listener name="JMS-ESBListener" busidref="quickstartEsbChannel" maxThreads="1"/>
</listeners>
- <actions mep="RequestResponse">
+ <actions>
<action name="print-before" class="org.jboss.soa.esb.actions.SystemPrintln">
<property name="message"
value="[Quickstart_webservice_producer] BEFORE invoking jbossws endpoint"/>
@@ -49,6 +49,11 @@
<property name="message"
value="[Quickstart_webservice_producer] AFTER invoking jbossws endpoint"/>
</action>
+ <action name="AddProperty"
+ class="org.jboss.soa.esb.actions.PropertySetter">
+ <property name="jbesbfilename" value="WebServiceProducerTest.log"/>
+ </action>
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
</actions>
</service>
Modified: labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_producer/src/org/jboss/soa/esb/samples/quickstart/webserviceproducer/test/SendMessage.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_producer/src/org/jboss/soa/esb/samples/quickstart/webserviceproducer/test/SendMessage.java 2007-11-26 03:53:44 UTC (rev 16798)
+++ labs/jbossesb/branches/JBESB_4_2_1_GA_CP/product/samples/quickstarts/webservice_producer/src/org/jboss/soa/esb/samples/quickstart/webserviceproducer/test/SendMessage.java 2007-11-26 04:09:17 UTC (rev 16799)
@@ -35,6 +35,8 @@
import javax.naming.NamingException;
import java.net.InetAddress;
+import org.jboss.soa.esb.actions.StoreMessageToFile;
+
public class SendMessage {
QueueConnection conn;
QueueSession session;
@@ -49,6 +51,7 @@
sender = session.createSender(que);
tm = session.createObjectMessage(message);
+ tm.setStringProperty(StoreMessageToFile.PROPERTY_JBESB_FILENAME, "WebServiceProducerTest.log");
sender.send(tm);
} finally {
if(sender != null) {
@@ -107,14 +110,11 @@
SendMessage sm = new SendMessage();
String msg = getMessage("01");
- sm.sendMessageToJBRListener("http", 8765, msg);
- /*
String protocol = args[0];
if(protocol.equals("jms")) {
sm.sendMessageOverJMS(msg);
} else {
sm.sendMessageToJBRListener(protocol, Integer.parseInt(args[1]), msg);
}
- */
}
-}
\ No newline at end of file
+}
More information about the jboss-svn-commits
mailing list