You are viewing a plain text version of this content. The canonical link for it is here.
Posted to fx-dev@ws.apache.org by ch...@apache.org on 2006/10/17 08:35:37 UTC
svn commit: r464827 [1/6] - in /webservices/sandesha/trunk/java:
interop/src/org/apache/sandesha2/interop/rm1_1_clients/
samples/src/sandesha2/samples/userguide/
src/org/apache/sandesha2/transport/ test/src/org/apache/sandesha2/
test/src/org/apache/san...
Author: chamikara
Date: Mon Oct 16 23:35:33 2006
New Revision: 464827
URL: http://svn.apache.org/viewvc?view=rev&rev=464827
Log:
Patch from Matt on Sandesha2-35.
Added the listener stoping method calls to the TestCases to fix test failures.
Modified:
webservices/sandesha/trunk/java/interop/src/org/apache/sandesha2/interop/rm1_1_clients/Scenario_1_1.java
webservices/sandesha/trunk/java/interop/src/org/apache/sandesha2/interop/rm1_1_clients/Scenario_1_2.java
webservices/sandesha/trunk/java/interop/src/org/apache/sandesha2/interop/rm1_1_clients/Scenario_1_3.java
webservices/sandesha/trunk/java/interop/src/org/apache/sandesha2/interop/rm1_1_clients/Scenario_1_4.java
webservices/sandesha/trunk/java/interop/src/org/apache/sandesha2/interop/rm1_1_clients/Scenario_2_1.java
webservices/sandesha/trunk/java/interop/src/org/apache/sandesha2/interop/rm1_1_clients/Scenario_2_2.java
webservices/sandesha/trunk/java/interop/src/org/apache/sandesha2/interop/rm1_1_clients/Scenario_2_3.java
webservices/sandesha/trunk/java/interop/src/org/apache/sandesha2/interop/rm1_1_clients/Scenario_3_1.java
webservices/sandesha/trunk/java/interop/src/org/apache/sandesha2/interop/rm1_1_clients/Scenario_4_1.java
webservices/sandesha/trunk/java/interop/src/org/apache/sandesha2/interop/rm1_1_clients/Scenario_4_2.java
webservices/sandesha/trunk/java/samples/src/sandesha2/samples/userguide/AsyncEchoClient.java
webservices/sandesha/trunk/java/samples/src/sandesha2/samples/userguide/AsyncEchoWithPollingClient.java
webservices/sandesha/trunk/java/samples/src/sandesha2/samples/userguide/AsyncPingClient.java
webservices/sandesha/trunk/java/samples/src/sandesha2/samples/userguide/MTOMPingClient.java
webservices/sandesha/trunk/java/samples/src/sandesha2/samples/userguide/SyncEchoClient.java
webservices/sandesha/trunk/java/samples/src/sandesha2/samples/userguide/SyncPingClient.java
webservices/sandesha/trunk/java/samples/src/sandesha2/samples/userguide/UserguidePingClient.java
webservices/sandesha/trunk/java/src/org/apache/sandesha2/transport/Sandesha2TransportSender.java
webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/MessageContextPropertyTest.java
webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/MessageRetransmissionTest.java
webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/SandeshaClientTest.java
webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/SandeshaReportsTest.java
webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/SquenceOfferTest.java
webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/mtom/MTOMRMTest.java
webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/scenarios/AddressableEchoTest.java
webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/scenarios/AddressablePingTest.java
webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/scenarios/AnonymousAckEchoTest.java
webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/scenarios/AnonymousPingTest.java
webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/scenarios/OptionalReliabilityTest.java
webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/security/SecurityTest.java
webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/versions/AddressingVersionTest.java
webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/versions/RMVersionTest.java
webservices/sandesha/trunk/java/test/src/org/apache/sandesha2/versions/SOAPVersionTest.java
Modified: webservices/sandesha/trunk/java/interop/src/org/apache/sandesha2/interop/rm1_1_clients/Scenario_1_1.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/interop/src/org/apache/sandesha2/interop/rm1_1_clients/Scenario_1_1.java?view=diff&rev=464827&r1=464826&r2=464827
==============================================================================
--- webservices/sandesha/trunk/java/interop/src/org/apache/sandesha2/interop/rm1_1_clients/Scenario_1_1.java (original)
+++ webservices/sandesha/trunk/java/interop/src/org/apache/sandesha2/interop/rm1_1_clients/Scenario_1_1.java Mon Oct 16 23:35:33 2006
@@ -1,212 +1,222 @@
-/*
- * Copyright 2004,2005 The Apache Software Foundation.
- *
- * Licensed under the Apache License, Version 2.0 (the "License"); you may not
- * use this file except in compliance with the License. You may obtain a copy of
- * the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
- * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
- * License for the specific language governing permissions and limitations under
- * the License.
- */
-
-package org.apache.sandesha2.interop.rm1_1_clients;
-
-import java.io.File;
-import java.io.IOException;
-import java.io.InputStream;
-import java.rmi.RemoteException;
-import java.util.Properties;
-
-import org.apache.axiom.om.OMAbstractFactory;
-import org.apache.axiom.om.OMElement;
-import org.apache.axiom.om.OMFactory;
-import org.apache.axiom.om.OMNamespace;
-import org.apache.axiom.soap.SOAP12Constants;
-import org.apache.axis2.AxisFault;
-import org.apache.axis2.addressing.EndpointReference;
-import org.apache.axis2.client.Options;
-import org.apache.axis2.client.ServiceClient;
-import org.apache.axis2.context.ConfigurationContext;
-import org.apache.axis2.context.ConfigurationContextFactory;
-import org.apache.axis2.context.MessageContextConstants;
-import org.apache.axis2.engine.AxisError;
-import org.apache.sandesha2.Sandesha2Constants;
-import org.apache.sandesha2.SandeshaException;
-import org.apache.sandesha2.client.SandeshaClient;
-import org.apache.sandesha2.client.SandeshaClientConstants;
-import org.apache.sandesha2.client.SequenceReport;
-import org.apache.sandesha2.interop.RMInteropServiceStub;
-import org.tempuri.Ping;
-
-public class Scenario_1_1 {
-
- private static final String applicationNamespaceName = "http://tempuri.org/";
- private static final String PingRequest = "PingRequest";
- private static final String Text = "Text";
-
- private static String toIP = "127.0.0.1";
- private static String toPort = "9762";
- private static String transportToIP = "127.0.0.1";
- private static String transportToPort = "8070";
- private static String servicePart = "/axis2/services/RMInteropService";
- private static String toEPR = "http://" + toIP + ":" + toPort + servicePart;
- private static String transportToEPR = "http://" + transportToIP + ":" + transportToPort + servicePart;
-
- private static String SANDESHA2_HOME = "<SANDESHA2_HOME>"; //Change this to ur path.
-
- private static String AXIS2_CLIENT_PATH = SANDESHA2_HOME + File.separator + "target" + File.separator +"repos" + File.separator + "client" + File.separator; //this will be available after a maven build
-
- public static void main(String[] args) throws Exception {
-
- String axisClientRepo = null;
- if (args!=null && args.length>0)
- axisClientRepo = args[0];
-
- if (axisClientRepo!=null && !"".equals(axisClientRepo)) {
- AXIS2_CLIENT_PATH = axisClientRepo;
- SANDESHA2_HOME = "";
- }
-
- InputStream in = Thread.currentThread().getContextClassLoader().getResourceAsStream("sandesha2_interop.properties");
-
- Properties properties = new Properties();
- if (in != null) {
- properties.load(in);
-
- toEPR = properties.getProperty("to");
- transportToEPR = properties.getProperty("transportTo");
- }
-
-
-// new Scenario_1_1 ().run();
-
- new Scenario_1_1 ().runStubBased ();
- }
-
- private void run () throws Exception {
-
- ConfigurationContext configurationContext = generateConfigContext();
-
- Options clientOptions = new Options ();
- setUpOptions(clientOptions);
-
- ServiceClient serviceClient = new ServiceClient (configurationContext,null);
-
- serviceClient.setOptions(clientOptions);
-
- serviceClient.fireAndForget(getPingOMBlock("ping1"));
- serviceClient.fireAndForget(getPingOMBlock("ping2"));
- serviceClient.fireAndForget(getPingOMBlock("ping3"));
-
- SequenceReport sequenceReport = null;
- boolean complete = false;
- while (!complete) {
- sequenceReport = SandeshaClient.getOutgoingSequenceReport(serviceClient);
- if (sequenceReport!=null && sequenceReport.getCompletedMessages().size()==1)
- complete = true;
- else {
- try {
- Thread.sleep(1000);
- } catch (InterruptedException e1) {
- e1.printStackTrace();
- }
- }
- }
-
- SandeshaClient.terminateSequence(serviceClient);
-
- serviceClient.finalizeInvoke();
- }
-
- private static OMElement getPingOMBlock(String text) {
- OMFactory fac = OMAbstractFactory.getOMFactory();
- OMNamespace namespace = fac.createOMNamespace(applicationNamespaceName,"ns1");
- OMElement pingElem = fac.createOMElement(PingRequest, namespace);
- OMElement textElem = fac.createOMElement(Text, null);
-
- textElem.setText(text);
- pingElem.addChild(textElem);
-
- return pingElem;
- }
-
- private void runStubBased () throws Exception {
- String targetEndpoint = toEPR;
- ConfigurationContext configurationContext = generateConfigContext();
-
- RMInteropServiceStub stub = new RMInteropServiceStub (configurationContext, targetEndpoint);
- ServiceClient stubServiceClient = stub._getServiceClient();
- setUpOptions(stubServiceClient.getOptions());
-
- Ping ping = new Ping ();
- ping.setText("ping1");
- stub.Ping (ping);
-
- ping = new Ping ();
- ping.setText("ping2");
- stub.Ping (ping);
-
- ping = new Ping ();
- ping.setText("ping3");
- stub.Ping (ping);
-
-
- SequenceReport sequenceReport = null;
- boolean complete = false;
- while (!complete) {
- sequenceReport = SandeshaClient.getOutgoingSequenceReport(stubServiceClient);
- if (sequenceReport!=null && sequenceReport.getCompletedMessages().size()==3)
- complete = true;
- else {
- try {
- Thread.sleep(1000);
- } catch (InterruptedException e1) {
- e1.printStackTrace();
- }
- }
- }
-
- SandeshaClient.terminateSequence(stubServiceClient);
-
- Thread.sleep(3000);
-
- stub._getServiceClient().finalizeInvoke();
- }
-
- private ConfigurationContext generateConfigContext () throws Exception {
- if ("<SANDESHA2_HOME>".equals(SANDESHA2_HOME)){
- System.out.println("ERROR: Please change <SANDESHA2_HOME> to your Sandesha2 installation directory.");
- throw new Exception ("Client not set up correctly");
- }
-
- String axis2_xml = AXIS2_CLIENT_PATH + "client_axis2.xml";
- ConfigurationContext configContext = ConfigurationContextFactory.createConfigurationContextFromFileSystem(AXIS2_CLIENT_PATH,axis2_xml);
-
- return configContext;
- }
-
- private void setUpOptions (Options clientOptions) {
- clientOptions.setProperty(MessageContextConstants.TRANSPORT_URL,transportToEPR);
-// clientOptions.setProperty(Options.COPY_PROPERTIES, new Boolean (true));
- clientOptions.setTo(new EndpointReference (toEPR));
-
- String sequenceKey = "sequence1";
- clientOptions.setProperty(SandeshaClientConstants.SEQUENCE_KEY,sequenceKey);
-
-// clientOptions.setProperty(MessageContextConstants.CHUNKED,Constants.VALUE_FALSE); //uncomment this to send messages without chunking.
-
- clientOptions.setSoapVersionURI(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI); //uncomment this to send messages in SOAP 1.2
-// clientOptions.setProperty(AddressingConstants.WS_ADDRESSING_VERSION,AddressingConstants.Submission.WSA_NAMESPACE);
- clientOptions.setProperty(SandeshaClientConstants.RM_SPEC_VERSION,Sandesha2Constants.SPEC_VERSIONS.v1_1); //uncomment this to send the messages according to the v1_1 spec.
-
- clientOptions.setAction("urn:wsrm:Ping");
-
- }
-
-
-}
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+
+package org.apache.sandesha2.interop.rm1_1_clients;
+
+import java.io.File;
+import java.io.IOException;
+import java.io.InputStream;
+import java.rmi.RemoteException;
+import java.util.Properties;
+
+import org.apache.axiom.om.OMAbstractFactory;
+import org.apache.axiom.om.OMElement;
+import org.apache.axiom.om.OMFactory;
+import org.apache.axiom.om.OMNamespace;
+import org.apache.axiom.soap.SOAP11Constants;
+import org.apache.axiom.soap.SOAP12Constants;
+import org.apache.axis2.AxisFault;
+import org.apache.axis2.addressing.EndpointReference;
+import org.apache.axis2.client.Options;
+import org.apache.axis2.client.ServiceClient;
+import org.apache.axis2.context.ConfigurationContext;
+import org.apache.axis2.context.ConfigurationContextFactory;
+import org.apache.axis2.context.MessageContextConstants;
+import org.apache.axis2.engine.AxisError;
+import org.apache.sandesha2.Sandesha2Constants;
+import org.apache.sandesha2.SandeshaException;
+import org.apache.sandesha2.client.SandeshaClient;
+import org.apache.sandesha2.client.SandeshaClientConstants;
+import org.apache.sandesha2.client.SequenceReport;
+import org.apache.sandesha2.interop.RMInteropServiceStub;
+import org.tempuri.Ping;
+
+public class Scenario_1_1 {
+
+ private static final String applicationNamespaceName = "http://tempuri.org/";
+ private static final String PingRequest = "PingRequest";
+ private static final String Text = "Text";
+
+ private static String toIP = "127.0.0.1";
+ private static String toPort = "9762";
+ private static String transportToIP = "127.0.0.1";
+ private static String transportToPort = "8070";
+ private static String servicePart = "/axis2/services/RMInteropService";
+ private static String toEPR = "http://" + toIP + ":" + toPort + servicePart;
+ private static String transportToEPR = "http://" + transportToIP + ":" + transportToPort + servicePart;
+
+ private static String SANDESHA2_HOME = "<SANDESHA2_HOME>"; //Change this to ur path.
+
+ private static String AXIS2_CLIENT_PATH = SANDESHA2_HOME + File.separator + "target" + File.separator +"repos" + File.separator + "client" + File.separator; //this will be available after a maven build
+
+ public static void main(String[] args) throws Exception {
+
+ String axisClientRepo = null;
+ if (args!=null && args.length>0)
+ axisClientRepo = args[0];
+
+ if (axisClientRepo!=null && !"".equals(axisClientRepo)) {
+ AXIS2_CLIENT_PATH = axisClientRepo;
+ SANDESHA2_HOME = "";
+ }
+
+ InputStream in = Thread.currentThread().getContextClassLoader().getResourceAsStream("sandesha2_interop.properties");
+
+ Properties properties = new Properties();
+ if (in != null) {
+ properties.load(in);
+
+ toEPR = properties.getProperty("to");
+ transportToEPR = properties.getProperty("transportTo");
+ }
+
+
+// new Scenario_1_1 ().run();
+
+ new Scenario_1_1 ().runStubBased ();
+ }
+
+ private void run () throws Exception {
+
+ ConfigurationContext configurationContext = generateConfigContext();
+
+ Options clientOptions = new Options ();
+ setUpOptions(clientOptions);
+
+ ServiceClient serviceClient = new ServiceClient (configurationContext,null);
+
+ serviceClient.setOptions(clientOptions);
+
+ serviceClient.fireAndForget(getPingOMBlock("ping1"));
+ serviceClient.fireAndForget(getPingOMBlock("ping2"));
+ serviceClient.fireAndForget(getPingOMBlock("ping3"));
+
+ SequenceReport sequenceReport = null;
+ boolean complete = false;
+ while (!complete) {
+ sequenceReport = SandeshaClient.getOutgoingSequenceReport(serviceClient);
+ if (sequenceReport!=null && sequenceReport.getCompletedMessages().size()==1)
+ complete = true;
+ else {
+ try {
+ Thread.sleep(1000);
+ } catch (InterruptedException e1) {
+ e1.printStackTrace();
+ }
+ }
+ }
+
+ SandeshaClient.terminateSequence(serviceClient);
+
+ serviceClient.cleanup();
+ }
+
+ private static OMElement getPingOMBlock(String text) {
+ OMFactory fac = OMAbstractFactory.getOMFactory();
+ OMNamespace namespace = fac.createOMNamespace(applicationNamespaceName,"ns1");
+ OMElement pingElem = fac.createOMElement(PingRequest, namespace);
+ OMElement textElem = fac.createOMElement(Text, null);
+
+ textElem.setText(text);
+ pingElem.addChild(textElem);
+
+ return pingElem;
+ }
+
+ private void runStubBased () throws Exception {
+ String targetEndpoint = toEPR;
+ ConfigurationContext configurationContext = generateConfigContext();
+
+ RMInteropServiceStub stub = new RMInteropServiceStub (configurationContext, targetEndpoint);
+ ServiceClient stubServiceClient = stub._getServiceClient();
+ setUpOptions(stubServiceClient.getOptions());
+
+ Ping ping = new Ping ();
+ ping.setText("ping1");
+ stub.Ping (ping);
+
+ ping = new Ping ();
+ ping.setText("ping2");
+ stub.Ping (ping);
+
+ ping = new Ping ();
+ ping.setText("ping3");
+ stub.Ping (ping);
+
+
+ SequenceReport sequenceReport = null;
+ boolean complete = false;
+ while (!complete) {
+ sequenceReport = SandeshaClient.getOutgoingSequenceReport(stubServiceClient);
+ if (sequenceReport!=null && sequenceReport.getCompletedMessages().size()==3)
+ complete = true;
+ else {
+ try {
+ Thread.sleep(1000);
+ } catch (InterruptedException e1) {
+ e1.printStackTrace();
+ }
+ }
+ }
+
+// SandeshaClient.closeSequence (stubServiceClient);
+
+ Thread.sleep(1000);
+
+ SandeshaClient.terminateSequence (stubServiceClient);
+
+ Thread.sleep(3000);
+
+// ping = new Ping ();
+// ping.setText("ping4");
+// stub.Ping (ping);
+// Thread.sleep(3000000);
+
+ stub._getServiceClient().cleanup();
+ }
+
+ private ConfigurationContext generateConfigContext () throws Exception {
+ if ("<SANDESHA2_HOME>".equals(SANDESHA2_HOME)){
+ System.out.println("ERROR: Please change <SANDESHA2_HOME> to your Sandesha2 installation directory.");
+ throw new Exception ("Client not set up correctly");
+ }
+
+ String axis2_xml = AXIS2_CLIENT_PATH + "client_axis2.xml";
+ ConfigurationContext configContext = ConfigurationContextFactory.createConfigurationContextFromFileSystem(AXIS2_CLIENT_PATH,axis2_xml);
+
+ return configContext;
+ }
+
+ private void setUpOptions (Options clientOptions) {
+ clientOptions.setProperty(MessageContextConstants.TRANSPORT_URL,transportToEPR);
+// clientOptions.setProperty(Options.COPY_PROPERTIES, new Boolean (true));
+ clientOptions.setTo(new EndpointReference (toEPR));
+
+ String sequenceKey = "sequence1";
+ clientOptions.setProperty(SandeshaClientConstants.SEQUENCE_KEY,sequenceKey);
+
+// clientOptions.setProperty(MessageContextConstants.CHUNKED,Constants.VALUE_FALSE); //uncomment this to send messages without chunking.
+
+ clientOptions.setSoapVersionURI(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI); //uncomment this to send messages in SOAP 1.2
+// clientOptions.setProperty(AddressingConstants.WS_ADDRESSING_VERSION,AddressingConstants.Submission.WSA_NAMESPACE);
+ clientOptions.setProperty(SandeshaClientConstants.RM_SPEC_VERSION,Sandesha2Constants.SPEC_VERSIONS.v1_1); //uncomment this to send the messages according to the v1_1 spec.
+
+ clientOptions.setAction("urn:wsrm:Ping");
+
+ }
+
+
+}
Modified: webservices/sandesha/trunk/java/interop/src/org/apache/sandesha2/interop/rm1_1_clients/Scenario_1_2.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/interop/src/org/apache/sandesha2/interop/rm1_1_clients/Scenario_1_2.java?view=diff&rev=464827&r1=464826&r2=464827
==============================================================================
--- webservices/sandesha/trunk/java/interop/src/org/apache/sandesha2/interop/rm1_1_clients/Scenario_1_2.java (original)
+++ webservices/sandesha/trunk/java/interop/src/org/apache/sandesha2/interop/rm1_1_clients/Scenario_1_2.java Mon Oct 16 23:35:33 2006
@@ -1,225 +1,226 @@
-/*
- * Copyright 2004,2005 The Apache Software Foundation.
- *
- * Licensed under the Apache License, Version 2.0 (the "License"); you may not
- * use this file except in compliance with the License. You may obtain a copy of
- * the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
- * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
- * License for the specific language governing permissions and limitations under
- * the License.
- */
-
-package org.apache.sandesha2.interop.rm1_1_clients;
-
-import java.io.File;
-import java.io.IOException;
-import java.io.InputStream;
-import java.util.Properties;
-
-import org.apache.axiom.om.OMAbstractFactory;
-import org.apache.axiom.om.OMElement;
-import org.apache.axiom.om.OMFactory;
-import org.apache.axiom.om.OMNamespace;
-import org.apache.axiom.soap.SOAP12Constants;
-import org.apache.axis2.AxisFault;
-import org.apache.axis2.addressing.EndpointReference;
-import org.apache.axis2.client.Options;
-import org.apache.axis2.client.ServiceClient;
-import org.apache.axis2.context.ConfigurationContext;
-import org.apache.axis2.context.ConfigurationContextFactory;
-import org.apache.axis2.context.MessageContextConstants;
-import org.apache.sandesha2.Sandesha2Constants;
-import org.apache.sandesha2.SandeshaException;
-import org.apache.sandesha2.client.SandeshaClient;
-import org.apache.sandesha2.client.SandeshaClientConstants;
-import org.apache.sandesha2.client.SequenceReport;
-import org.apache.sandesha2.interop.RMInteropServiceStub;
-
-public class Scenario_1_2 {
-
- private static final String applicationNamespaceName = "http://tempuri.org/";
- private static final String ping = "ping";
- private static final String Text = "Text";
-
- private static String toIP = "127.0.0.1";
- private static String toPort = "9762";
- private static String transportToIP = "127.0.0.1";
- private static String transportToPort = "8070";
- private static String servicePart = "/axis2/services/RMInteropService";
- private static String toEPR = "http://" + toIP + ":" + toPort + servicePart;
- private static String transportToEPR = "http://" + transportToIP + ":" + transportToPort + servicePart;
-
- private static String SANDESHA2_HOME = "<SANDESHA2_HOME>"; //Change this to ur path.
-
- private static String AXIS2_CLIENT_PATH = SANDESHA2_HOME + File.separator + "target" + File.separator +"repos" + File.separator + "client" + File.separator; //this will be available after a maven build
-
- public static void main(String[] args) throws Exception {
-
- String axisClientRepo = null;
- if (args!=null && args.length>0)
- axisClientRepo = args[0];
-
- if (axisClientRepo!=null && !"".equals(axisClientRepo)) {
- AXIS2_CLIENT_PATH = axisClientRepo;
- SANDESHA2_HOME = "";
- }
-
- InputStream in = Thread.currentThread().getContextClassLoader().getResourceAsStream("sandesha2_interop.properties");
-
- Properties properties = new Properties();
- if (in != null) {
- properties.load(in);
-
- toEPR = properties.getProperty("to");
- transportToEPR = properties.getProperty("transportTo");
- }
-
- new Scenario_1_2 ().run();
-// new Scenario_1_2 ().runStubBased ();
- }
-
- private void run () throws Exception {
-
- ConfigurationContext configurationContext = generateConfigContext();
- Options clientOptions = new Options ();
- setUpOptions(clientOptions);
-
- ServiceClient serviceClient = new ServiceClient (configurationContext,null);
- serviceClient.setOptions(clientOptions);
-
- SandeshaClient.createSequence(serviceClient, false);
-
- SequenceReport sequenceReport = null;
- boolean established = false;
- while (!established) {
- sequenceReport = SandeshaClient.getOutgoingSequenceReport(serviceClient);
- if (sequenceReport!=null && sequenceReport.getSequenceStatus()>=SequenceReport.SEQUENCE_STATUS_ESTABLISHED)
- established = true;
- else {
- try {
- Thread.sleep(100);
- } catch (InterruptedException e1) {
- e1.printStackTrace();
- }
- }
- }
-
- SandeshaClient.sendAckRequest(serviceClient);
-
- SandeshaClient.terminateSequence(serviceClient);
-
- boolean terminated = false;
- while (!terminated) {
- sequenceReport = SandeshaClient.getOutgoingSequenceReport(serviceClient);
- if (sequenceReport!=null && sequenceReport.getSequenceStatus()==SequenceReport.SEQUENCE_STATUS_TERMINATED)
- terminated = true;
- else {
- try {
- Thread.sleep(1000);
- } catch (InterruptedException e1) {
- e1.printStackTrace();
- }
- }
- }
-
-// serviceClient.finalizeInvoke();
- }
-
- private static OMElement getPingOMBlock(String text) {
- OMFactory fac = OMAbstractFactory.getOMFactory();
- OMNamespace namespace = fac.createOMNamespace(applicationNamespaceName,"ns1");
- OMElement pingElem = fac.createOMElement(ping, namespace);
- OMElement textElem = fac.createOMElement(Text, namespace);
-
- textElem.setText(text);
- pingElem.addChild(textElem);
-
- return pingElem;
- }
-
-
- private void runStubBased () throws Exception {
- String targetEndpoint = toEPR;
- ConfigurationContext configurationContext = generateConfigContext();
-
- RMInteropServiceStub stub = new RMInteropServiceStub (configurationContext, targetEndpoint);
-
- setUpOptions(stub._getServiceClient().getOptions());
- ServiceClient stubServiceClient = stub._getServiceClient();
- Options clientOptions = stubServiceClient.getOptions();
-
-// stubServiceClient.setOptions(clientOptions);
-
- setUpOptions(clientOptions);
-
- SandeshaClient.createSequence(stubServiceClient, false);
-
- SequenceReport sequenceReport = null;
- boolean established = false;
- while (!established) {
- sequenceReport = SandeshaClient.getOutgoingSequenceReport(stubServiceClient);
- if (sequenceReport!=null && sequenceReport.getSequenceStatus()>=SequenceReport.SEQUENCE_STATUS_ESTABLISHED)
- established = true;
- else {
- try {
- Thread.sleep(100);
- } catch (InterruptedException e1) {
- e1.printStackTrace();
- }
- }
- }
-
- SandeshaClient.sendAckRequest(stubServiceClient);
-
- SandeshaClient.terminateSequence(stubServiceClient);
-
- boolean terminated = false;
- while (!terminated) {
- sequenceReport = SandeshaClient.getOutgoingSequenceReport(stubServiceClient);
- if (sequenceReport!=null && sequenceReport.getSequenceStatus()==SequenceReport.SEQUENCE_STATUS_TERMINATED)
- terminated = true;
- else {
- try {
- Thread.sleep(1000);
- } catch (InterruptedException e1) {
- e1.printStackTrace();
- }
- }
- }
-
- }
-
- private ConfigurationContext generateConfigContext () throws Exception {
- if ("<SANDESHA2_HOME>".equals(SANDESHA2_HOME)){
- System.out.println("ERROR: Please change <SANDESHA2_HOME> to your Sandesha2 installation directory.");
- throw new Exception ("Client not set up correctly");
- }
-
- String axis2_xml = AXIS2_CLIENT_PATH + "client_axis2.xml";
- ConfigurationContext configContext = ConfigurationContextFactory.createConfigurationContextFromFileSystem(AXIS2_CLIENT_PATH,axis2_xml);
-
- return configContext;
- }
-
- private void setUpOptions (Options clientOptions) {
- clientOptions.setProperty(MessageContextConstants.TRANSPORT_URL,transportToEPR);
- clientOptions.setTo(new EndpointReference (toEPR));
-
- String sequenceKey = "sequence1";
- clientOptions.setProperty(SandeshaClientConstants.SEQUENCE_KEY,sequenceKey);
-
-// clientOptions.setProperty(MessageContextConstants.CHUNKED,Constants.VALUE_FALSE); //uncomment this to send messages without chunking.
- clientOptions.setSoapVersionURI(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI); //uncomment this to send messages in SOAP 1.2
-// clientOptions.setProperty(AddressingConstants.WS_ADDRESSING_VERSION,AddressingConstants.Submission.WSA_NAMESPACE);
- clientOptions.setProperty(SandeshaClientConstants.RM_SPEC_VERSION,Sandesha2Constants.SPEC_VERSIONS.v1_1); //uncomment this to send the messages according to the v1_1 spec.
-
- clientOptions.setAction("urn:wsrm:Ping");
- }
-
-
-}
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+
+package org.apache.sandesha2.interop.rm1_1_clients;
+
+import java.io.File;
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.Properties;
+
+import org.apache.axiom.om.OMAbstractFactory;
+import org.apache.axiom.om.OMElement;
+import org.apache.axiom.om.OMFactory;
+import org.apache.axiom.om.OMNamespace;
+import org.apache.axiom.soap.SOAP11Constants;
+import org.apache.axiom.soap.SOAP12Constants;
+import org.apache.axis2.AxisFault;
+import org.apache.axis2.addressing.EndpointReference;
+import org.apache.axis2.client.Options;
+import org.apache.axis2.client.ServiceClient;
+import org.apache.axis2.context.ConfigurationContext;
+import org.apache.axis2.context.ConfigurationContextFactory;
+import org.apache.axis2.context.MessageContextConstants;
+import org.apache.sandesha2.Sandesha2Constants;
+import org.apache.sandesha2.SandeshaException;
+import org.apache.sandesha2.client.SandeshaClient;
+import org.apache.sandesha2.client.SandeshaClientConstants;
+import org.apache.sandesha2.client.SequenceReport;
+import org.apache.sandesha2.interop.RMInteropServiceStub;
+
+public class Scenario_1_2 {
+
+ private static final String applicationNamespaceName = "http://tempuri.org/";
+ private static final String ping = "ping";
+ private static final String Text = "Text";
+
+ private static String toIP = "127.0.0.1";
+ private static String toPort = "9762";
+ private static String transportToIP = "127.0.0.1";
+ private static String transportToPort = "8070";
+ private static String servicePart = "/axis2/services/RMInteropService";
+ private static String toEPR = "http://" + toIP + ":" + toPort + servicePart;
+ private static String transportToEPR = "http://" + transportToIP + ":" + transportToPort + servicePart;
+
+ private static String SANDESHA2_HOME = "<SANDESHA2_HOME>"; //Change this to ur path.
+
+ private static String AXIS2_CLIENT_PATH = SANDESHA2_HOME + File.separator + "target" + File.separator +"repos" + File.separator + "client" + File.separator; //this will be available after a maven build
+
+ public static void main(String[] args) throws Exception {
+
+ String axisClientRepo = null;
+ if (args!=null && args.length>0)
+ axisClientRepo = args[0];
+
+ if (axisClientRepo!=null && !"".equals(axisClientRepo)) {
+ AXIS2_CLIENT_PATH = axisClientRepo;
+ SANDESHA2_HOME = "";
+ }
+
+ InputStream in = Thread.currentThread().getContextClassLoader().getResourceAsStream("sandesha2_interop.properties");
+
+ Properties properties = new Properties();
+ if (in != null) {
+ properties.load(in);
+
+ toEPR = properties.getProperty("to");
+ transportToEPR = properties.getProperty("transportTo");
+ }
+
+ new Scenario_1_2 ().run();
+// new Scenario_1_2 ().runStubBased ();
+ }
+
+ private void run () throws Exception {
+
+ ConfigurationContext configurationContext = generateConfigContext();
+ Options clientOptions = new Options ();
+ setUpOptions(clientOptions);
+
+ ServiceClient serviceClient = new ServiceClient (configurationContext,null);
+ serviceClient.setOptions(clientOptions);
+
+ SandeshaClient.createSequence(serviceClient, false);
+
+ SequenceReport sequenceReport = null;
+ boolean established = false;
+ while (!established) {
+ sequenceReport = SandeshaClient.getOutgoingSequenceReport(serviceClient);
+ if (sequenceReport!=null && sequenceReport.getSequenceStatus()>=SequenceReport.SEQUENCE_STATUS_ESTABLISHED)
+ established = true;
+ else {
+ try {
+ Thread.sleep(100);
+ } catch (InterruptedException e1) {
+ e1.printStackTrace();
+ }
+ }
+ }
+
+ SandeshaClient.sendAckRequest(serviceClient);
+
+ SandeshaClient.terminateSequence(serviceClient);
+
+ boolean terminated = false;
+ while (!terminated) {
+ sequenceReport = SandeshaClient.getOutgoingSequenceReport(serviceClient);
+ if (sequenceReport!=null && sequenceReport.getSequenceStatus()==SequenceReport.SEQUENCE_STATUS_TERMINATED)
+ terminated = true;
+ else {
+ try {
+ Thread.sleep(1000);
+ } catch (InterruptedException e1) {
+ e1.printStackTrace();
+ }
+ }
+ }
+
+// serviceClient.cleanup();
+ }
+
+ private static OMElement getPingOMBlock(String text) {
+ OMFactory fac = OMAbstractFactory.getOMFactory();
+ OMNamespace namespace = fac.createOMNamespace(applicationNamespaceName,"ns1");
+ OMElement pingElem = fac.createOMElement(ping, namespace);
+ OMElement textElem = fac.createOMElement(Text, namespace);
+
+ textElem.setText(text);
+ pingElem.addChild(textElem);
+
+ return pingElem;
+ }
+
+
+ private void runStubBased () throws Exception {
+ String targetEndpoint = toEPR;
+ ConfigurationContext configurationContext = generateConfigContext();
+
+ RMInteropServiceStub stub = new RMInteropServiceStub (configurationContext, targetEndpoint);
+
+ setUpOptions(stub._getServiceClient().getOptions());
+ ServiceClient stubServiceClient = stub._getServiceClient();
+ Options clientOptions = stubServiceClient.getOptions();
+
+// stubServiceClient.setOptions(clientOptions);
+
+ setUpOptions(clientOptions);
+
+ SandeshaClient.createSequence(stubServiceClient, false);
+
+ SequenceReport sequenceReport = null;
+ boolean established = false;
+ while (!established) {
+ sequenceReport = SandeshaClient.getOutgoingSequenceReport(stubServiceClient);
+ if (sequenceReport!=null && sequenceReport.getSequenceStatus()>=SequenceReport.SEQUENCE_STATUS_ESTABLISHED)
+ established = true;
+ else {
+ try {
+ Thread.sleep(100);
+ } catch (InterruptedException e1) {
+ e1.printStackTrace();
+ }
+ }
+ }
+
+ SandeshaClient.sendAckRequest(stubServiceClient);
+
+ SandeshaClient.terminateSequence(stubServiceClient);
+
+ boolean terminated = false;
+ while (!terminated) {
+ sequenceReport = SandeshaClient.getOutgoingSequenceReport(stubServiceClient);
+ if (sequenceReport!=null && sequenceReport.getSequenceStatus()==SequenceReport.SEQUENCE_STATUS_TERMINATED)
+ terminated = true;
+ else {
+ try {
+ Thread.sleep(1000);
+ } catch (InterruptedException e1) {
+ e1.printStackTrace();
+ }
+ }
+ }
+
+ }
+
+ private ConfigurationContext generateConfigContext () throws Exception {
+ if ("<SANDESHA2_HOME>".equals(SANDESHA2_HOME)){
+ System.out.println("ERROR: Please change <SANDESHA2_HOME> to your Sandesha2 installation directory.");
+ throw new Exception ("Client not set up correctly");
+ }
+
+ String axis2_xml = AXIS2_CLIENT_PATH + "client_axis2.xml";
+ ConfigurationContext configContext = ConfigurationContextFactory.createConfigurationContextFromFileSystem(AXIS2_CLIENT_PATH,axis2_xml);
+
+ return configContext;
+ }
+
+ private void setUpOptions (Options clientOptions) {
+ clientOptions.setProperty(MessageContextConstants.TRANSPORT_URL,transportToEPR);
+ clientOptions.setTo(new EndpointReference (toEPR));
+
+ String sequenceKey = "sequence1";
+ clientOptions.setProperty(SandeshaClientConstants.SEQUENCE_KEY,sequenceKey);
+
+// clientOptions.setProperty(MessageContextConstants.CHUNKED,Constants.VALUE_FALSE); //uncomment this to send messages without chunking.
+ clientOptions.setSoapVersionURI(SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI); //uncomment this to send messages in SOAP 1.2
+// clientOptions.setProperty(AddressingConstants.WS_ADDRESSING_VERSION,AddressingConstants.Submission.WSA_NAMESPACE);
+ clientOptions.setProperty(SandeshaClientConstants.RM_SPEC_VERSION,Sandesha2Constants.SPEC_VERSIONS.v1_1); //uncomment this to send the messages according to the v1_1 spec.
+
+ clientOptions.setAction("urn:wsrm:Ping");
+ }
+
+
+}
Modified: webservices/sandesha/trunk/java/interop/src/org/apache/sandesha2/interop/rm1_1_clients/Scenario_1_3.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/interop/src/org/apache/sandesha2/interop/rm1_1_clients/Scenario_1_3.java?view=diff&rev=464827&r1=464826&r2=464827
==============================================================================
--- webservices/sandesha/trunk/java/interop/src/org/apache/sandesha2/interop/rm1_1_clients/Scenario_1_3.java (original)
+++ webservices/sandesha/trunk/java/interop/src/org/apache/sandesha2/interop/rm1_1_clients/Scenario_1_3.java Mon Oct 16 23:35:33 2006
@@ -1,246 +1,233 @@
-/*
- * Copyright 2004,2005 The Apache Software Foundation.
- *
- * Licensed under the Apache License, Version 2.0 (the "License"); you may not
- * use this file except in compliance with the License. You may obtain a copy of
- * the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
- * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
- * License for the specific language governing permissions and limitations under
- * the License.
- */
-
-package org.apache.sandesha2.interop.rm1_1_clients;
-
-import java.io.File;
-import java.io.IOException;
-import java.io.InputStream;
-import java.util.Properties;
-
-import org.apache.axiom.om.OMAbstractFactory;
-import org.apache.axiom.om.OMElement;
-import org.apache.axiom.om.OMFactory;
-import org.apache.axiom.om.OMNamespace;
-import org.apache.axiom.soap.SOAP12Constants;
-import org.apache.axis2.AxisFault;
-import org.apache.axis2.addressing.EndpointReference;
-import org.apache.axis2.client.Options;
-import org.apache.axis2.client.ServiceClient;
-import org.apache.axis2.context.ConfigurationContext;
-import org.apache.axis2.context.ConfigurationContextFactory;
-import org.apache.axis2.context.MessageContextConstants;
-import org.apache.sandesha2.Sandesha2Constants;
-import org.apache.sandesha2.client.SandeshaClient;
-import org.apache.sandesha2.client.SandeshaClientConstants;
-import org.apache.sandesha2.client.SequenceReport;
-import org.apache.sandesha2.interop.RMInteropServiceStub;
-import org.tempuri.Ping;
-
-public class Scenario_1_3 {
-
- private static final String applicationNamespaceName = "http://tempuri.org/";
- private static final String ping = "ping";
- private static final String Text = "Text";
-
- private static String toIP = "127.0.0.1";
- private static String toPort = "9762";
- private static String transportToIP = "127.0.0.1";
- private static String transportToPort = "8070";
- private static String servicePart = "/axis2/services/RMInteropService";
- private static String toEPR = "http://" + toIP + ":" + toPort + servicePart;
- private static String transportToEPR = "http://" + transportToIP + ":" + transportToPort + servicePart;
-
- private static String SANDESHA2_HOME = "<SANDESHA2_HOME>"; //Change this to ur path.
-
- private static String AXIS2_CLIENT_PATH = SANDESHA2_HOME + File.separator + "target" + File.separator +"repos" + File.separator + "client" + File.separator; //this will be available after a maven build
-
- public static void main(String[] args) throws Exception {
-
- String axisClientRepo = null;
- if (args!=null && args.length>0)
- axisClientRepo = args[0];
-
- if (axisClientRepo!=null && !"".equals(axisClientRepo)) {
- AXIS2_CLIENT_PATH = axisClientRepo;
- SANDESHA2_HOME = "";
- }
-
- InputStream in = Thread.currentThread().getContextClassLoader().getResourceAsStream("sandesha2_interop.properties");
-
- Properties properties = new Properties();
- if (in != null) {
- properties.load(in);
-
- toEPR = properties.getProperty("to");
- transportToEPR = properties.getProperty("transportTo");
- }
-
-// new Scenario_1_3 ().run();
- new Scenario_1_3 ().runStubBased ();
-
- Thread.sleep(60000);
- }
-
- private void run () throws Exception {
-
-
- ConfigurationContext configurationContext = generateConfigContext();
-
- Options clientOptions = new Options ();
- setUpOptions(clientOptions);
-
- ServiceClient serviceClient = new ServiceClient (configurationContext,null);
- serviceClient.setOptions(clientOptions);
-
- clientOptions.setProperty(SandeshaClientConstants.MESSAGE_NUMBER,new Long(1));
- serviceClient.fireAndForget(getPingOMBlock("ping1"));
-
- clientOptions.setProperty(SandeshaClientConstants.MESSAGE_NUMBER,new Long(3));
- serviceClient.fireAndForget(getPingOMBlock("ping3"));
-
- boolean complete = false;
- while (!complete) {
- SequenceReport sequenceReport = SandeshaClient.getOutgoingSequenceReport(serviceClient);
- if (sequenceReport!=null && sequenceReport.getCompletedMessages().size()==2)
- complete = true;
- else {
- try {
- Thread.sleep(1000);
- } catch (InterruptedException e1) {
- e1.printStackTrace();
- }
- }
- }
-
- SandeshaClient.closeSequence(serviceClient);
-
-// try {
-// Thread.sleep(3000);
-// } catch (InterruptedException e) {
-// // TODO Auto-generated catch block
-// e.printStackTrace();
-// }
-
-// clientOptions.setProperty(SandeshaClientConstants.MESSAGE_NUMBER,new Long(4));
-// serviceClient.fireAndForget(getPingOMBlock("ping4"));
-
- try {
- Thread.sleep(3000);
- } catch (InterruptedException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
-
- SandeshaClient.terminateSequence(serviceClient);
-
- try {
- Thread.sleep(3000);
- } catch (InterruptedException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
-
- serviceClient.finalizeInvoke();
- }
-
- private static OMElement getPingOMBlock(String text) {
- OMFactory fac = OMAbstractFactory.getOMFactory();
- OMNamespace namespace = fac.createOMNamespace(applicationNamespaceName,"ns1");
- OMElement pingElem = fac.createOMElement(ping, namespace);
- OMElement textElem = fac.createOMElement(Text, namespace);
-
- textElem.setText(text);
- pingElem.addChild(textElem);
-
- return pingElem;
- }
-
- private void runStubBased () throws Exception {
-
- ConfigurationContext configurationContext = generateConfigContext();
- RMInteropServiceStub stub = new RMInteropServiceStub (configurationContext,toEPR);
- ServiceClient stubServiceClient = stub._getServiceClient();
-
- Options options = stubServiceClient.getOptions();
- setUpOptions(options);
-
- options.setProperty(SandeshaClientConstants.MESSAGE_NUMBER,new Long(1));
- Ping ping = new Ping ();
- ping.setText("ping1");
- stub.Ping(ping);
-
- options.setProperty(SandeshaClientConstants.MESSAGE_NUMBER,new Long(3));
- ping = new Ping ();
- ping.setText("ping2");
- stub.Ping(ping);
-
- boolean complete = false;
- while (!complete) {
- SequenceReport sequenceReport = SandeshaClient.getOutgoingSequenceReport(stubServiceClient);
- if (sequenceReport!=null && sequenceReport.getCompletedMessages().size()==2)
- complete = true;
- else {
- try {
- Thread.sleep(1000);
- } catch (InterruptedException e1) {
- e1.printStackTrace();
- }
- }
- }
-
- SandeshaClient.closeSequence(stubServiceClient);
-
- try {
- Thread.sleep(6000);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
-
- SandeshaClient.terminateSequence(stubServiceClient);
-
- try {
- Thread.sleep(3000000);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
-
- stubServiceClient.finalizeInvoke();
-
-
- }
-
- private ConfigurationContext generateConfigContext () throws Exception {
- if ("<SANDESHA2_HOME>".equals(SANDESHA2_HOME)){
- System.out.println("ERROR: Please change <SANDESHA2_HOME> to your Sandesha2 installation directory.");
- throw new Exception ("Client not set up correctly");
- }
-
- String axis2_xml = AXIS2_CLIENT_PATH + "client_axis2.xml";
- ConfigurationContext configContext = ConfigurationContextFactory.createConfigurationContextFromFileSystem(AXIS2_CLIENT_PATH,axis2_xml);
-
- return configContext;
- }
-
- private void setUpOptions (Options clientOptions) {
- clientOptions.setProperty(MessageContextConstants.TRANSPORT_URL,transportToEPR);
-// clientOptions.setProperty(Options.COPY_PROPERTIES, new Boolean (true));
- clientOptions.setTo(new EndpointReference (toEPR));
-
- String sequenceKey = "sequence1";
- clientOptions.setProperty(SandeshaClientConstants.SEQUENCE_KEY,sequenceKey);
-
-// clientOptions.setProperty(MessageContextConstants.CHUNKED,Constants.VALUE_FALSE); //uncomment this to send messages without chunking.
-
- clientOptions.setSoapVersionURI(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI); //uncomment this to send messages in SOAP 1.2
-// clientOptions.setProperty(AddressingConstants.WS_ADDRESSING_VERSION,AddressingConstants.Submission.WSA_NAMESPACE);
- clientOptions.setProperty(SandeshaClientConstants.RM_SPEC_VERSION,Sandesha2Constants.SPEC_VERSIONS.v1_1); //uncomment this to send the messages according to the v1_1 spec.
-
- clientOptions.setAction("urn:wsrm:Ping");
-
- }
-
-}
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+
+package org.apache.sandesha2.interop.rm1_1_clients;
+
+import java.io.File;
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.Properties;
+
+import org.apache.axiom.om.OMAbstractFactory;
+import org.apache.axiom.om.OMElement;
+import org.apache.axiom.om.OMFactory;
+import org.apache.axiom.om.OMNamespace;
+import org.apache.axiom.soap.SOAP12Constants;
+import org.apache.axis2.AxisFault;
+import org.apache.axis2.addressing.EndpointReference;
+import org.apache.axis2.client.Options;
+import org.apache.axis2.client.ServiceClient;
+import org.apache.axis2.context.ConfigurationContext;
+import org.apache.axis2.context.ConfigurationContextFactory;
+import org.apache.axis2.context.MessageContextConstants;
+import org.apache.sandesha2.Sandesha2Constants;
+import org.apache.sandesha2.client.SandeshaClient;
+import org.apache.sandesha2.client.SandeshaClientConstants;
+import org.apache.sandesha2.client.SequenceReport;
+import org.apache.sandesha2.interop.RMInteropServiceStub;
+import org.tempuri.Ping;
+
+public class Scenario_1_3 {
+
+ private static final String applicationNamespaceName = "http://tempuri.org/";
+ private static final String ping = "ping";
+ private static final String Text = "Text";
+
+ private static String toIP = "127.0.0.1";
+ private static String toPort = "9762";
+ private static String transportToIP = "127.0.0.1";
+ private static String transportToPort = "8070";
+ private static String servicePart = "/axis2/services/RMInteropService";
+ private static String toEPR = "http://" + toIP + ":" + toPort + servicePart;
+ private static String transportToEPR = "http://" + transportToIP + ":" + transportToPort + servicePart;
+
+ private static String SANDESHA2_HOME = "<SANDESHA2_HOME>"; //Change this to ur path.
+
+ private static String AXIS2_CLIENT_PATH = SANDESHA2_HOME + File.separator + "target" + File.separator +"repos" + File.separator + "client" + File.separator; //this will be available after a maven build
+
+ public static void main(String[] args) throws Exception {
+
+ String axisClientRepo = null;
+ if (args!=null && args.length>0)
+ axisClientRepo = args[0];
+
+ if (axisClientRepo!=null && !"".equals(axisClientRepo)) {
+ AXIS2_CLIENT_PATH = axisClientRepo;
+ SANDESHA2_HOME = "";
+ }
+
+ InputStream in = Thread.currentThread().getContextClassLoader().getResourceAsStream("sandesha2_interop.properties");
+
+ Properties properties = new Properties();
+ if (in != null) {
+ properties.load(in);
+
+ toEPR = properties.getProperty("to");
+ transportToEPR = properties.getProperty("transportTo");
+ }
+
+// new Scenario_1_3 ().run();
+ new Scenario_1_3 ().runStubBased ();
+
+ Thread.sleep(60000);
+ }
+
+ private void run () throws Exception {
+
+
+ ConfigurationContext configurationContext = generateConfigContext();
+
+ Options clientOptions = new Options ();
+ setUpOptions(clientOptions);
+
+ ServiceClient serviceClient = new ServiceClient (configurationContext,null);
+ serviceClient.setOptions(clientOptions);
+
+ clientOptions.setProperty(SandeshaClientConstants.MESSAGE_NUMBER,new Long(1));
+ serviceClient.fireAndForget(getPingOMBlock("ping1"));
+
+ clientOptions.setProperty(SandeshaClientConstants.MESSAGE_NUMBER,new Long(3));
+ serviceClient.fireAndForget(getPingOMBlock("ping3"));
+
+ boolean complete = false;
+ while (!complete) {
+ SequenceReport sequenceReport = SandeshaClient.getOutgoingSequenceReport(serviceClient);
+ if (sequenceReport!=null && sequenceReport.getCompletedMessages().size()==2)
+ complete = true;
+ else {
+ try {
+ Thread.sleep(1000);
+ } catch (InterruptedException e1) {
+ e1.printStackTrace();
+ }
+ }
+ }
+
+ SandeshaClient.closeSequence(serviceClient);
+
+ try {
+ Thread.sleep(3000);
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }
+
+ SandeshaClient.terminateSequence(serviceClient);
+
+ try {
+ Thread.sleep(3000);
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }
+
+ serviceClient.cleanup();
+ }
+
+ private static OMElement getPingOMBlock(String text) {
+ OMFactory fac = OMAbstractFactory.getOMFactory();
+ OMNamespace namespace = fac.createOMNamespace(applicationNamespaceName,"ns1");
+ OMElement pingElem = fac.createOMElement(ping, namespace);
+ OMElement textElem = fac.createOMElement(Text, namespace);
+
+ textElem.setText(text);
+ pingElem.addChild(textElem);
+
+ return pingElem;
+ }
+
+ private void runStubBased () throws Exception {
+
+ ConfigurationContext configurationContext = generateConfigContext();
+ RMInteropServiceStub stub = new RMInteropServiceStub (configurationContext,toEPR);
+ ServiceClient stubServiceClient = stub._getServiceClient();
+
+ Options options = stubServiceClient.getOptions();
+ setUpOptions(options);
+
+ options.setProperty(SandeshaClientConstants.MESSAGE_NUMBER,new Long(1));
+ Ping ping = new Ping ();
+ ping.setText("ping1");
+ stub.Ping(ping);
+
+ options.setProperty(SandeshaClientConstants.MESSAGE_NUMBER,new Long(3));
+ ping = new Ping ();
+ ping.setText("ping2");
+ stub.Ping(ping);
+
+ boolean complete = false;
+ while (!complete) {
+ SequenceReport sequenceReport = SandeshaClient.getOutgoingSequenceReport(stubServiceClient);
+ if (sequenceReport!=null && sequenceReport.getCompletedMessages().size()==2)
+ complete = true;
+ else {
+ try {
+ Thread.sleep(1000);
+ } catch (InterruptedException e1) {
+ e1.printStackTrace();
+ }
+ }
+ }
+
+ SandeshaClient.closeSequence(stubServiceClient);
+
+ try {
+ Thread.sleep(6000);
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }
+
+ SandeshaClient.terminateSequence(stubServiceClient);
+
+ try {
+ Thread.sleep(3000000);
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }
+
+ stubServiceClient.cleanup();
+
+
+ }
+
+ private ConfigurationContext generateConfigContext () throws Exception {
+ if ("<SANDESHA2_HOME>".equals(SANDESHA2_HOME)){
+ System.out.println("ERROR: Please change <SANDESHA2_HOME> to your Sandesha2 installation directory.");
+ throw new Exception ("Client not set up correctly");
+ }
+
+ String axis2_xml = AXIS2_CLIENT_PATH + "client_axis2.xml";
+ ConfigurationContext configContext = ConfigurationContextFactory.createConfigurationContextFromFileSystem(AXIS2_CLIENT_PATH,axis2_xml);
+
+ return configContext;
+ }
+
+ private void setUpOptions (Options clientOptions) {
+ clientOptions.setProperty(MessageContextConstants.TRANSPORT_URL,transportToEPR);
+// clientOptions.setProperty(Options.COPY_PROPERTIES, new Boolean (true));
+ clientOptions.setTo(new EndpointReference (toEPR));
+
+ String sequenceKey = "sequence1";
+ clientOptions.setProperty(SandeshaClientConstants.SEQUENCE_KEY,sequenceKey);
+
+// clientOptions.setProperty(MessageContextConstants.CHUNKED,Constants.VALUE_FALSE); //uncomment this to send messages without chunking.
+ clientOptions.setSoapVersionURI(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI); //uncomment this to send messages in SOAP 1.2
+// clientOptions.setProperty(AddressingConstants.WS_ADDRESSING_VERSION,AddressingConstants.Submission.WSA_NAMESPACE);
+ clientOptions.setProperty(SandeshaClientConstants.RM_SPEC_VERSION,Sandesha2Constants.SPEC_VERSIONS.v1_1); //uncomment this to send the messages according to the v1_1 spec.
+
+ clientOptions.setAction("urn:wsrm:Ping");
+
+ }
+
+}
Modified: webservices/sandesha/trunk/java/interop/src/org/apache/sandesha2/interop/rm1_1_clients/Scenario_1_4.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/interop/src/org/apache/sandesha2/interop/rm1_1_clients/Scenario_1_4.java?view=diff&rev=464827&r1=464826&r2=464827
==============================================================================
--- webservices/sandesha/trunk/java/interop/src/org/apache/sandesha2/interop/rm1_1_clients/Scenario_1_4.java (original)
+++ webservices/sandesha/trunk/java/interop/src/org/apache/sandesha2/interop/rm1_1_clients/Scenario_1_4.java Mon Oct 16 23:35:33 2006
@@ -1,225 +1,230 @@
-/*
- * Copyright 2004,2005 The Apache Software Foundation.
- *
- * Licensed under the Apache License, Version 2.0 (the "License"); you may not
- * use this file except in compliance with the License. You may obtain a copy of
- * the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
- * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
- * License for the specific language governing permissions and limitations under
- * the License.
- */
-
-package org.apache.sandesha2.interop.rm1_1_clients;
-
-import java.io.File;
-import java.io.IOException;
-import java.io.InputStream;
-import java.util.Properties;
-
-import org.apache.axiom.om.OMAbstractFactory;
-import org.apache.axiom.om.OMElement;
-import org.apache.axiom.om.OMFactory;
-import org.apache.axiom.om.OMNamespace;
-import org.apache.axiom.soap.SOAP12Constants;
-import org.apache.axis2.AxisFault;
-import org.apache.axis2.Constants;
-import org.apache.axis2.addressing.EndpointReference;
-import org.apache.axis2.client.Options;
-import org.apache.axis2.client.ServiceClient;
-import org.apache.axis2.context.ConfigurationContext;
-import org.apache.axis2.context.ConfigurationContextFactory;
-import org.apache.axis2.context.MessageContextConstants;
-import org.apache.sandesha2.Sandesha2Constants;
-import org.apache.sandesha2.client.SandeshaClient;
-import org.apache.sandesha2.client.SandeshaClientConstants;
-import org.apache.sandesha2.client.SequenceReport;
-import org.apache.sandesha2.interop.RMInteropServiceStub;
-import org.tempuri.Ping;
-
-public class Scenario_1_4 {
-
- private static final String applicationNamespaceName = "http://tempuri.org/";
-
- private static final String ping = "ping";
-
- private static final String Text = "Text";
-
- private static String toIP = "127.0.0.1";
- private static String toPort = "9762";
- private static String transportToIP = "127.0.0.1";
- private static String transportToPort = "8070";
- private static String servicePart = "/axis2/services/RMInteropService";
- private static String toEPR = "http://" + toIP + ":" + toPort + servicePart;
- private static String transportToEPR = "http://" + transportToIP + ":" + transportToPort + servicePart;
-
- private static String SANDESHA2_HOME = "<SANDESHA2_HOME>"; // Change
- // this
- // to
- // ur
- // path.
-
- private static String AXIS2_CLIENT_PATH = SANDESHA2_HOME + File.separator
- + "target" + File.separator + "repos" + File.separator + "client"
- + File.separator; // this will be available after a maven build
-
- public static void main(String[] args) throws Exception {
-
- String axisClientRepo = null;
- if (args != null && args.length > 0)
- axisClientRepo = args[0];
-
- if (axisClientRepo != null && !"".equals(axisClientRepo)) {
- AXIS2_CLIENT_PATH = axisClientRepo;
- SANDESHA2_HOME = "";
- }
-
- InputStream in = Thread.currentThread().getContextClassLoader().getResourceAsStream("sandesha2_interop.properties");
-
- Properties properties = new Properties();
- if (in != null) {
- properties.load(in);
-
- toEPR = properties.getProperty("to");
- transportToEPR = properties.getProperty("transportTo");
- }
-
-// new Scenario_1_4().run();
- new Scenario_1_4().runStubBased ();
- }
-
- private void run() throws Exception {
-
- ConfigurationContext configurationContext = generateConfigContext();
-
- ServiceClient serviceClient = new ServiceClient(configurationContext, null);
-
-// String replyAddress = serviceClient.getMyEPR(Constants.TRANSPORT_HTTP).getAddress() + "/" + ServiceClient.ANON_OUT_ONLY_OP;
- String acksToAddress = serviceClient.getMyEPR(Constants.TRANSPORT_HTTP).getAddress();
-
- Options clientOptions = new Options();
- setUpOptions(clientOptions,acksToAddress);
-
- serviceClient.setOptions(clientOptions);
-
- serviceClient.fireAndForget(getPingOMBlock("ping1"));
- serviceClient.fireAndForget(getPingOMBlock("ping2"));
- serviceClient.fireAndForget(getPingOMBlock("ping3"));
-
- boolean complete = false;
- while (!complete) {
- SequenceReport sequenceReport = SandeshaClient.getOutgoingSequenceReport(serviceClient);
- if (sequenceReport!=null && sequenceReport.getCompletedMessages().size()==3)
- complete = true;
- else {
- try {
- Thread.sleep(1000);
- } catch (InterruptedException e1) {
- e1.printStackTrace();
- }
- }
- }
-
- SandeshaClient.terminateSequence(serviceClient);
-
- Thread.sleep(3000);
-
- serviceClient.finalizeInvoke();
- }
-
- private static OMElement getPingOMBlock(String text) {
- OMFactory fac = OMAbstractFactory.getOMFactory();
- OMNamespace namespace = fac.createOMNamespace(applicationNamespaceName,
- "ns1");
- OMElement pingElem = fac.createOMElement(ping, namespace);
- OMElement textElem = fac.createOMElement(Text, namespace);
-
- textElem.setText(text);
- pingElem.addChild(textElem);
-
- return pingElem;
- }
-
- private void runStubBased () throws Exception {
- String targetEndpoint = toEPR;
- ConfigurationContext configurationContext = generateConfigContext();
-
- RMInteropServiceStub stub = new RMInteropServiceStub (configurationContext, targetEndpoint);
- ServiceClient stubServiceClient = stub._getServiceClient();
-
- String acksToAddress = stubServiceClient.getMyEPR(Constants.TRANSPORT_HTTP).getAddress();
-
- setUpOptions(stubServiceClient.getOptions(),acksToAddress);
-
-
- Ping ping = new Ping ();
- ping.setText("ping1");
- stub.Ping(ping);
-
- ping = new Ping ();
- ping.setText("ping2");
- stub.Ping(ping);
-
- ping = new Ping ();
- ping.setText("ping3");
- stub.Ping(ping);
-
- SequenceReport sequenceReport = null;
- boolean complete = false;
- while (!complete) {
- sequenceReport = SandeshaClient.getOutgoingSequenceReport(stubServiceClient);
- if (sequenceReport!=null && sequenceReport.getCompletedMessages().size()==3)
- complete = true;
- else {
- try {
- Thread.sleep(1000);
- } catch (InterruptedException e1) {
- e1.printStackTrace();
- }
- }
- }
-
- SandeshaClient.terminateSequence(stubServiceClient);
- stub._getServiceClient().finalizeInvoke();
-
- }
-
- private ConfigurationContext generateConfigContext () throws Exception {
- if ("<SANDESHA2_HOME>".equals(SANDESHA2_HOME)){
- System.out.println("ERROR: Please change <SANDESHA2_HOME> to your Sandesha2 installation directory.");
- throw new Exception ("Client not set up correctly");
- }
-
- String axis2_xml = AXIS2_CLIENT_PATH + "client_axis2.xml";
- ConfigurationContext configContext = ConfigurationContextFactory.createConfigurationContextFromFileSystem(AXIS2_CLIENT_PATH,axis2_xml);
-
- return configContext;
- }
-
- private void setUpOptions (Options clientOptions, String acksTo) {
- clientOptions.setProperty(MessageContextConstants.TRANSPORT_URL,transportToEPR);
-// clientOptions.setProperty(Options.COPY_PROPERTIES, new Boolean (true));
- clientOptions.setTo(new EndpointReference (toEPR));
-
- String sequenceKey = "sequence1";
- clientOptions.setProperty(SandeshaClientConstants.SEQUENCE_KEY,sequenceKey);
-
-// clientOptions.setProperty(MessageContextConstants.CHUNKED,Constants.VALUE_FALSE); //uncomment this to send messages without chunking.
-
- clientOptions.setSoapVersionURI(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI); //uncomment this to send messages in SOAP 1.2
-// clientOptions.setProperty(AddressingConstants.WS_ADDRESSING_VERSION,AddressingConstants.Submission.WSA_NAMESPACE);
- clientOptions.setProperty(SandeshaClientConstants.RM_SPEC_VERSION,Sandesha2Constants.SPEC_VERSIONS.v1_1); //uncomment this to send the messages according to the v1_1 spec.
-
- clientOptions.setAction("urn:wsrm:Ping");
-
- clientOptions.setTransportInProtocol(Constants.TRANSPORT_HTTP);
-
- clientOptions.setProperty(SandeshaClientConstants.AcksTo, acksTo);
-
-
- }
-}
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+
+package org.apache.sandesha2.interop.rm1_1_clients;
+
+import java.io.File;
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.Properties;
+
+import org.apache.axiom.om.OMAbstractFactory;
+import org.apache.axiom.om.OMElement;
+import org.apache.axiom.om.OMFactory;
+import org.apache.axiom.om.OMNamespace;
+import org.apache.axiom.soap.SOAP12Constants;
+import org.apache.axis2.AxisFault;
+import org.apache.axis2.Constants;
+import org.apache.axis2.addressing.EndpointReference;
+import org.apache.axis2.client.Options;
+import org.apache.axis2.client.ServiceClient;
+import org.apache.axis2.context.ConfigurationContext;
+import org.apache.axis2.context.ConfigurationContextFactory;
+import org.apache.axis2.context.MessageContextConstants;
+import org.apache.sandesha2.Sandesha2Constants;
+import org.apache.sandesha2.client.SandeshaClient;
+import org.apache.sandesha2.client.SandeshaClientConstants;
+import org.apache.sandesha2.client.SequenceReport;
+import org.apache.sandesha2.interop.RMInteropServiceStub;
+import org.tempuri.Ping;
+
+public class Scenario_1_4 {
+
+ private static final String applicationNamespaceName = "http://tempuri.org/";
+
+ private static final String ping = "ping";
+
+ private static final String Text = "Text";
+
+ private static String toIP = "127.0.0.1";
+ private static String toPort = "9762";
+ private static String transportToIP = "127.0.0.1";
+ private static String transportToPort = "8070";
+ private static String servicePart = "/axis2/services/RMInteropService";
+ private static String toEPR = "http://" + toIP + ":" + toPort + servicePart;
+ private static String transportToEPR = "http://" + transportToIP + ":" + transportToPort + servicePart;
+
+ private static String SANDESHA2_HOME = "<SANDESHA2_HOME>"; // Change
+ // this
+ // to
+ // ur
+ // path.
+
+ private static String AXIS2_CLIENT_PATH = SANDESHA2_HOME + File.separator
+ + "target" + File.separator + "repos" + File.separator + "client"
+ + File.separator; // this will be available after a maven build
+
+ public static void main(String[] args) throws Exception {
+
+ String axisClientRepo = null;
+ if (args != null && args.length > 0)
+ axisClientRepo = args[0];
+
+ if (axisClientRepo != null && !"".equals(axisClientRepo)) {
+ AXIS2_CLIENT_PATH = axisClientRepo;
+ SANDESHA2_HOME = "";
+ }
+
+ InputStream in = Thread.currentThread().getContextClassLoader().getResourceAsStream("sandesha2_interop.properties");
+
+ Properties properties = new Properties();
+ if (in != null) {
+ properties.load(in);
+
+ toEPR = properties.getProperty("to");
+ transportToEPR = properties.getProperty("transportTo");
+ }
+
+// new Scenario_1_4().run();
+ new Scenario_1_4().runStubBased ();
+ }
+
+ private void run() throws Exception {
+
+ ConfigurationContext configurationContext = generateConfigContext();
+
+ ServiceClient serviceClient = new ServiceClient(configurationContext, null);
+
+// String replyAddress = serviceClient.getMyEPR(Constants.TRANSPORT_HTTP).getAddress() + "/" + ServiceClient.ANON_OUT_ONLY_OP;
+ String acksToAddress = serviceClient.getMyEPR(Constants.TRANSPORT_HTTP).getAddress();
+
+ Options clientOptions = new Options();
+ setUpOptions(clientOptions,acksToAddress);
+
+ serviceClient.setOptions(clientOptions);
+
+ serviceClient.fireAndForget(getPingOMBlock("ping1"));
+ serviceClient.fireAndForget(getPingOMBlock("ping2"));
+ serviceClient.fireAndForget(getPingOMBlock("ping3"));
+
+ boolean complete = false;
+ while (!complete) {
+ SequenceReport sequenceReport = SandeshaClient.getOutgoingSequenceReport(serviceClient);
+ if (sequenceReport!=null && sequenceReport.getCompletedMessages().size()==3)
+ complete = true;
+ else {
+ try {
+ Thread.sleep(1000);
+ } catch (InterruptedException e1) {
+ e1.printStackTrace();
+ }
+ }
+ }
+
+ SandeshaClient.terminateSequence(serviceClient);
+
+ Thread.sleep(3000);
+
+ serviceClient.cleanup();
+ }
+
+ private static OMElement getPingOMBlock(String text) {
+ OMFactory fac = OMAbstractFactory.getOMFactory();
+ OMNamespace namespace = fac.createOMNamespace(applicationNamespaceName,
+ "ns1");
+ OMElement pingElem = fac.createOMElement(ping, namespace);
+ OMElement textElem = fac.createOMElement(Text, namespace);
+
+ textElem.setText(text);
+ pingElem.addChild(textElem);
+
+ return pingElem;
+ }
+
+ private void runStubBased () throws Exception {
+ String targetEndpoint = toEPR;
+ ConfigurationContext configurationContext = generateConfigContext();
+
+ RMInteropServiceStub stub = new RMInteropServiceStub (configurationContext, targetEndpoint);
+ ServiceClient stubServiceClient = stub._getServiceClient();
+
+ String acksToAddress = stubServiceClient.getMyEPR(Constants.TRANSPORT_HTTP).getAddress();
+
+ setUpOptions(stubServiceClient.getOptions(),acksToAddress);
+
+ Ping ping = new Ping ();
+ ping.setText("ping1");
+ stub.Ping(ping);
+
+ ping = new Ping ();
+ ping.setText("ping2");
+ stub.Ping(ping);
+
+ ping = new Ping ();
+ ping.setText("ping3");
+ stub.Ping(ping);
+
+ SequenceReport sequenceReport = null;
+ boolean complete = false;
+ while (!complete) {
+ sequenceReport = SandeshaClient.getOutgoingSequenceReport(stubServiceClient);
+ if (sequenceReport!=null && sequenceReport.getCompletedMessages().size()==3)
+ complete = true;
+ else {
+ try {
+ Thread.sleep(1000);
+ } catch (InterruptedException e1) {
+ e1.printStackTrace();
+ }
+ }
+ }
+
+ Thread.sleep(3000);
+
+ SandeshaClient.terminateSequence(stubServiceClient);
+
+ Thread.sleep(6000);
+
+ stub._getServiceClient().cleanup();
+
+ }
+
+ private ConfigurationContext generateConfigContext () throws Exception {
+ if ("<SANDESHA2_HOME>".equals(SANDESHA2_HOME)){
+ System.out.println("ERROR: Please change <SANDESHA2_HOME> to your Sandesha2 installation directory.");
+ throw new Exception ("Client not set up correctly");
+ }
+
+ String axis2_xml = AXIS2_CLIENT_PATH + "client_axis2.xml";
+ ConfigurationContext configContext = ConfigurationContextFactory.createConfigurationContextFromFileSystem(AXIS2_CLIENT_PATH,axis2_xml);
+
+ return configContext;
+ }
+
+ private void setUpOptions (Options clientOptions, String acksTo) {
+ clientOptions.setProperty(MessageContextConstants.TRANSPORT_URL,transportToEPR);
+// clientOptions.setProperty(Options.COPY_PROPERTIES, new Boolean (true));
+ clientOptions.setTo(new EndpointReference (toEPR));
+
+ String sequenceKey = "sequence1";
+ clientOptions.setProperty(SandeshaClientConstants.SEQUENCE_KEY,sequenceKey);
+
+// clientOptions.setProperty(MessageContextConstants.CHUNKED,Constants.VALUE_FALSE); //uncomment this to send messages without chunking.
+
+ clientOptions.setSoapVersionURI(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI); //uncomment this to send messages in SOAP 1.2
+// clientOptions.setProperty(AddressingConstants.WS_ADDRESSING_VERSION,AddressingConstants.Submission.WSA_NAMESPACE);
+ clientOptions.setProperty(SandeshaClientConstants.RM_SPEC_VERSION,Sandesha2Constants.SPEC_VERSIONS.v1_1); //uncomment this to send the messages according to the v1_1 spec.
+
+ clientOptions.setAction("urn:wsrm:Ping");
+
+ clientOptions.setTransportInProtocol(Constants.TRANSPORT_HTTP);
+
+ clientOptions.setProperty(SandeshaClientConstants.AcksTo, acksTo);
+ clientOptions.setReplyTo(new EndpointReference (acksTo)); //making replyTo value same as AcksTo.
+
+
+ }
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org