Author: chamikara
Date: Thu Aug 3 10:12:32 2006
New Revision: 428454
URL: http://svn.apache.org/viewvc?rev=428454&view=rev
Log:
A client to test RM+MTOM message exchange.
Added:
webservices/sandesha/trunk/java/samples/src/sandesha2/samples/userguide/MTOMPingClient.java
Added:
webservices/sandesha/trunk/java/samples/src/sandesha2/samples/userguide/MTOMPingClient.java
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/samples/src/sandesha2/samples/userguide/MTOMPingClient.java?rev=428454&view=auto
==============================================================================
---
webservices/sandesha/trunk/java/samples/src/sandesha2/samples/userguide/MTOMPingClient.java
(added)
+++
webservices/sandesha/trunk/java/samples/src/sandesha2/samples/userguide/MTOMPingClient.java
Thu Aug 3 10:12:32 2006
@@ -0,0 +1,172 @@
+/*
+ * 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 sandesha2.samples.userguide;
+
+import java.awt.Image;
+import java.io.File;
+import java.io.FileInputStream;
+
+import javax.activation.DataHandler;
+import javax.xml.namespace.QName;
+
+import org.apache.axiom.attachments.utils.ImageDataSource;
+import org.apache.axiom.attachments.utils.ImageIO;
+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.om.OMText;
+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.client.SandeshaClient;
+import org.apache.sandesha2.client.SandeshaClientConstants;
+import org.apache.sandesha2.client.SandeshaListener;
+import org.apache.sandesha2.client.SequenceReport;
+import org.apache.sandesha2.util.SandeshaUtil;
+
+public class MTOMPingClient {
+
+ private static final String applicationNamespaceName =
"http://tempuri.org/";;
+ private static final String MTOMPing = "MTOMPing";
+ private static final String Text = "Text";
+
+ private String toIP = "127.0.0.1";
+
+ private String toPort = "8080";
+ private String transportToPort = "8070";
+
+ private String toEPR = "http://"; + toIP + ":" + toPort +
"/axis2/services/RMSampleService";
+ private String transportToEPR = "http://"; + toIP + ":" +
transportToPort + "/axis2/services/RMSampleService";
+
+ 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 AxisFault {
+
+ String axisClientRepo = null;
+ if (args!=null && args.length>0)
+ axisClientRepo = args[0];
+
+ if (axisClientRepo!=null && !"".equals(axisClientRepo)) {
+ AXIS2_CLIENT_PATH = axisClientRepo;
+ SANDESHA2_HOME = "";
+ }
+
+ new MTOMPingClient ().run();
+ }
+
+ private void run () throws AxisFault {
+
+ if ("<SANDESHA2_HOME>".equals(SANDESHA2_HOME)){
+ System.out.println("ERROR: Please change
<SANDESHA2_HOME> to your Sandesha2 installation directory.");
+ return;
+ }
+
+ String axis2_xml = AXIS2_CLIENT_PATH + "client_axis2.xml";
+ ConfigurationContext configContext =
ConfigurationContextFactory.createConfigurationContextFromFileSystem(AXIS2_CLIENT_PATH,axis2_xml);
+
+ Options clientOptions = new Options ();
+
clientOptions.setProperty(MessageContextConstants.TRANSPORT_URL,transportToEPR);
+ clientOptions.setTo(new EndpointReference (toEPR));
+
+ String sequenceKey = SandeshaUtil.getUUID();// "sequence2";
+
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(SandeshaClient.RM_SPEC_VERSION,Sandesha2Constants.SPEC_VERSIONS.v1_1);
//uncomment this to send the messages according to the v1_1 spec.
+
+//
clientOptions.setProperty(AddressingConstants.WS_ADDRESSING_VERSION,AddressingConstants.Submission.WSA_NAMESPACE);
+
+
clientOptions.setProperty(SandeshaClientConstants.SANDESHA_LISTENER, new
SandeshaListenerImpl ());
+ ServiceClient serviceClient = new ServiceClient
(configContext,null);
+ serviceClient.engageModule(new QName ("sandesha2"));
+
+ clientOptions.setAction("urn:wsrm:Ping");
+ serviceClient.setOptions(clientOptions);
+
+ clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE,
"true");
+
+ serviceClient.fireAndForget(getPingOMBlock());
+
+ SequenceReport sequenceReport = null;
+
+ boolean complete = false;
+ while (!complete) {
+ sequenceReport =
SandeshaClient.getOutgoingSequenceReport(serviceClient);
+ if (sequenceReport!=null &&
sequenceReport.getCompletedMessages().size()==3)
+ complete = true;
+ else {
+ try {
+ Thread.sleep(1000);
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }
+ }
+ }
+
+ serviceClient.finalizeInvoke();
+ }
+
+ private static OMElement getPingOMBlock() throws AxisFault {
+ OMFactory fac = OMAbstractFactory.getOMFactory();
+ OMNamespace namespace =
fac.createOMNamespace(applicationNamespaceName,"ns1");
+ OMElement pingElem = fac.createOMElement(MTOMPing, namespace);
+ OMElement attachmentElem = fac.createOMElement("Attachment",
namespace);
+
+ Image image;
+ String imageName = "test-resources" + File.separator +
"mtom-image.jpg";
+ ImageDataSource dataSource;
+ try {
+ image = new ImageIO().loadImage(new
FileInputStream(imageName));
+ dataSource = new ImageDataSource("test.jpg",image);
+ } catch (Exception e) {
+ throw new AxisFault (e);
+ }
+
+ DataHandler dataHandler = new DataHandler(dataSource);
+
+ OMText textData = fac.createOMText(dataHandler, true);
+ attachmentElem.addChild(textData);
+
+ pingElem.addChild(attachmentElem);
+
+ return pingElem;
+ }
+
+ private class SandeshaListenerImpl implements SandeshaListener {
+
+ public void onError(AxisFault fault) {
+ System.out.println("*********** RM fault callbak
called");
+ }
+
+ public void onTimeOut(SequenceReport report) {
+ System.out.println("Sequence timed out");
+ }
+ }
+
+}
+
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
