You are viewing a plain text version of this content. The canonical link for it is here.
Posted to java-dev@axis.apache.org by di...@apache.org on 2002/10/13 17:35:58 UTC
cvs commit: xml-axis/java/samples/client DynamicInvoker.java readme
dims 2002/10/13 08:35:58
Modified: java/test/dynamic build.xml PackageTests.java
Added: java/test/dynamic TestDynamicInvoker.java
java/samples/client DynamicInvoker.java readme
Log:
- Porting DynamicInvoker sample from WSIF (Uses Axis/JAXRPC's DII)
- Adding test case as well.
java samples.client.DynamicInvoker http://www.xmethods.net/sd/2001/TemperatureService.wsdl getTemp 02067
java samples.client.DynamicInvoker http://services.xmethods.net/soap/urn:xmethods-delayed-quotes.wsdl getQuote IBM
Revision Changes Path
1.8 +1 -0 xml-axis/java/test/dynamic/build.xml
Index: build.xml
===================================================================
RCS file: /home/cvs/xml-axis/java/test/dynamic/build.xml,v
retrieving revision 1.7
retrieving revision 1.8
diff -u -r1.7 -r1.8
--- build.xml 19 Sep 2002 15:58:00 -0000 1.7
+++ build.xml 13 Oct 2002 15:35:57 -0000 1.8
@@ -59,6 +59,7 @@
<path refid="classpath"/>
</classpath>
<include name="test/dynamic/*.java"/>
+ <include name="samples/client/*.java"/>
</javac>
</target>
1.2 +2 -1 xml-axis/java/test/dynamic/PackageTests.java
Index: PackageTests.java
===================================================================
RCS file: /home/cvs/xml-axis/java/test/dynamic/PackageTests.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- PackageTests.java 21 May 2002 15:43:02 -0000 1.1
+++ PackageTests.java 13 Oct 2002 15:35:57 -0000 1.2
@@ -60,7 +60,7 @@
import junit.framework.TestSuite;
/**
- * Test package for faults
+ * Test package for DII
*
* @author Mark Roder <mr...@wamnet.com>
*/
@@ -74,6 +74,7 @@
TestSuite suite = new TestSuite();
suite.addTestSuite(ServiceGetPort.class);
+ suite.addTestSuite(TestDynamicInvoker.class);
return suite;
}
1.1 xml-axis/java/test/dynamic/TestDynamicInvoker.java
Index: TestDynamicInvoker.java
===================================================================
/*
* The Apache Software License, Version 1.1
*
*
* Copyright (c) 2001 The Apache Software Foundation. All rights
* reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
*
* 1. Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
*
* 2. Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in
* the documentation and/or other materials provided with the
* distribution.
*
* 3. The end-user documentation included with the redistribution,
* if any, must include the following acknowledgment:
* "This product includes software developed by the
* Apache Software Foundation (http://www.apache.org/)."
* Alternately, this acknowledgment may appear in the software itself,
* if and wherever such third-party acknowledgments normally appear.
*
* 4. The names "Axis" and "Apache Software Foundation" must
* not be used to endorse or promote products derived from this
* software without prior written permission. For written
* permission, please contact apache@apache.org.
*
* 5. Products derived from this software may not be called "Apache",
* nor may "Apache" appear in their name, without prior written
* permission of the Apache Software Foundation.
*
* THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
* DISCLAIMED. IN NO EVENT SHALL THE APACHE SOFTWARE FOUNDATION OR
* ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
* USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
* OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
* OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
* SUCH DAMAGE.
* ====================================================================
*
* This software consists of voluntary contributions made by many
* individuals on behalf of the Apache Software Foundation. For more
* information on the Apache Software Foundation, please see
* <http://www.apache.org/>.
*/
package test.dynamic;
import samples.client.DynamicInvoker;
import junit.framework.TestCase;
public class TestDynamicInvoker extends TestCase {
public TestDynamicInvoker(String name) {
super(name);
} // ctor
public void test1() throws Exception {
String[] args = new String[]{"http://www.xmethods.net/sd/2001/TemperatureService.wsdl", "getTemp", "02067"};
DynamicInvoker invoker = new DynamicInvoker();
invoker.main(args);
}
public void test2() throws Exception {
String[] args = new String[]{"http://services.xmethods.net/soap/urn:xmethods-delayed-quotes.wsdl", "getQuote", "IBM"};
DynamicInvoker invoker = new DynamicInvoker();
invoker.main(args);
}
}
1.1 xml-axis/java/samples/client/DynamicInvoker.java
Index: DynamicInvoker.java
===================================================================
/*
* The Apache Software License, Version 1.1
*
*
* Copyright (c) 2001 The Apache Software Foundation. All rights
* reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
*
* 1. Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
*
* 2. Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in
* the documentation and/or other materials provided with the
* distribution.
*
* 3. The end-user documentation included with the redistribution,
* if any, must include the following acknowledgment:
* "This product includes software developed by the
* Apache Software Foundation (http://www.apache.org/)."
* Alternately, this acknowledgment may appear in the software itself,
* if and wherever such third-party acknowledgments normally appear.
*
* 4. The names "Axis" and "Apache Software Foundation" must
* not be used to endorse or promote products derived from this
* software without prior written permission. For written
* permission, please contact apache@apache.org.
*
* 5. Products derived from this software may not be called "Apache",
* nor may "Apache" appear in their name, without prior written
* permission of the Apache Software Foundation.
*
* THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
* DISCLAIMED. IN NO EVENT SHALL THE APACHE SOFTWARE FOUNDATION OR
* ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
* USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
* OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
* OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
* SUCH DAMAGE.
* ====================================================================
*
* This software consists of voluntary contributions made by many
* individuals on behalf of the Apache Software Foundation. For more
* information on the Apache Software Foundation, please see
* <http://www.apache.org/>.
*/
package samples.client;
import org.apache.axis.utils.XMLUtils;
import org.w3c.dom.Document;
import javax.wsdl.Binding;
import javax.wsdl.Definition;
import javax.wsdl.Import;
import javax.wsdl.Input;
import javax.wsdl.Message;
import javax.wsdl.Operation;
import javax.wsdl.Output;
import javax.wsdl.Part;
import javax.wsdl.Port;
import javax.wsdl.PortType;
import javax.wsdl.Service;
import javax.wsdl.factory.WSDLFactory;
import javax.wsdl.xml.WSDLReader;
import javax.xml.namespace.QName;
import javax.xml.rpc.Call;
import javax.xml.rpc.ServiceFactory;
import java.net.URL;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.StringTokenizer;
import java.util.Vector;
/**
* This sample shows how to use Axis for completely dynamic invocations
* as it is completely stubless execution. This sample does not support
* complex types (it could if there was defined a to encode complex
* values as command line arguments).
*
* @author Sanjiva Weerawarana
* @author Alekander Slominski
* @author Davanum Srinivas (dims@yahoo.com)
*/
public class DynamicInvoker {
private static void usage() {
System.err.println(
"Usage: java "
+ DynamicInvoker.class.getName()
+ " wsdlLocation "
+ "operationName[(portName)]:[inputMessageName]:[outputMessageName] "
+ "[argument1 ...]");
System.exit(1);
}
public static void main(String[] args) throws Exception {
if (args.length < 2)
usage();
String wsdlLocation = args.length > 0 ? args[0] : null;
String operationKey = args.length > 1 ? args[1] : null;
String portName = null;
String operationName = null;
String inputName = null;
String outputName = null;
StringTokenizer st = new StringTokenizer(operationKey, ":");
int tokens = st.countTokens();
int specType = 0;
if (tokens == 2) {
specType = operationKey.endsWith(":") ? 1 : 2;
} else if (tokens != 1 && tokens != 3)
usage();
while (st.hasMoreTokens()) {
if (operationName == null)
operationName = st.nextToken();
else if (inputName == null && specType != 2)
inputName = st.nextToken();
else if (outputName == null)
outputName = st.nextToken();
else
break;
}
try {
portName =
operationName.substring(operationName.indexOf("(") + 1, operationName.indexOf(")"));
operationName = operationName.substring(0, operationName.indexOf("("));
} catch (Exception ignored) {
}
HashMap map =
invokeMethod(
wsdlLocation,
operationName,
inputName,
outputName,
portName,
args);
// print result
System.out.println("Result:");
for (Iterator it = map.keySet().iterator(); it.hasNext();) {
String name = (String) it.next();
System.out.println(name + "=" + map.get(name));
}
System.out.println("\nDone!");
}
public static HashMap invokeMethod(
String wsdlLocation,
String operationName,
String inputName,
String outputName,
String portName,
String[] args)
throws Exception {
String serviceNS = null;
String serviceName = null;
String portTypeNS = null;
String portTypeName = null;
String portNS = null;
String operationQName = null;
System.out.println("Reading WSDL document from '" + wsdlLocation + "'");
WSDLReader reader = WSDLFactory.newInstance()
.newWSDLReader();
reader.setFeature("javax.wsdl.verbose", false);
Document doc = XMLUtils.newDocument(wsdlLocation);
Definition def = reader.readWSDL(null, doc);
System.out.println("Preparing Axis dynamic invocation");
Service service = selectService(def, serviceNS, serviceName);
PortType portType = selectPortType(def, portTypeNS, portTypeName);
ServiceFactory factory = ServiceFactory.newInstance();
javax.xml.rpc.Service dpf = factory.createService(new URL(wsdlLocation), service.getQName());
if (inputName == null && outputName == null) {
// retrieve list of operations
List operationList = portType.getOperations();
// try to find input and output names for the operation specified
boolean found = false;
for (Iterator i = operationList.iterator(); i.hasNext();) {
Operation op = (Operation) i.next();
String name = op.getName();
if (!name.equals(operationName)) {
continue;
}
if (found) {
throw new RuntimeException(
"Operation '"
+ operationName
+ "' is overloaded. "
+ "Please specify the operation in the form "
+ "'operationName:inputMessageName:outputMesssageName' to distinguish it");
}
found = true;
Input opInput = op.getInput();
inputName = (opInput.getName() == null) ? null : opInput.getName();
Output opOutput = op.getOutput();
outputName = (opOutput.getName() == null) ? null : opOutput.getName();
}
}
Vector inputs = new Vector();
if (portName == null) {
Port port = selectPort(service.getPorts(), portNS, portName);
portName = port.getName();
}
Call call = dpf.createCall(QName.valueOf(portName), QName.valueOf(operationName));
// retrieve list of names and types for input and names for output
List operationList = portType.getOperations();
// find portType operation to prepare in/oout message w/ parts
boolean found = false;
String[] outNames = new String[0];
Class[] outTypes = new Class[0];
for (Iterator i = operationList.iterator(); i.hasNext();) {
Operation op = (Operation) i.next();
String name = op.getName();
if (!name.equals(operationName)) {
continue;
}
if (found) {
throw new RuntimeException("overloaded operations are not supported in this sample");
}
found = true;
//System.err.println("op = "+op);
Input opInput = op.getInput();
// first determine list of arguments
String[] inNames = new String[0];
Class[] inTypes = new Class[0];
if (opInput != null) {
List parts = opInput.getMessage().getOrderedParts(null);
int count = parts.size();
inNames = new String[count];
inTypes = new Class[count];
retrieveSignature(parts, inNames, inTypes);
}
// now prepare out parameters
for (int pos = 0; pos < inNames.length; ++pos) {
String arg = args[pos + 2];
Object value = null;
Class c = inTypes[pos];
if (c.equals(String.class)) {
value = arg;
} else if (c.equals(Double.TYPE)) {
value = new Double(arg);
} else if (c.equals(Float.TYPE)) {
value = new Float(arg);
} else if (c.equals(Integer.TYPE)) {
value = new Integer(arg);
} else if (c.equals(Boolean.TYPE)) {
value = new Boolean(arg);
} else {
throw new RuntimeException("not know how to convert '" + arg + "' into " + c);
}
inputs.add(value);
}
Output opOutput = op.getOutput();
if (opOutput != null) {
List parts = opOutput.getMessage().getOrderedParts(null);
int count = parts.size();
outNames = new String[count];
outTypes = new Class[count];
retrieveSignature(parts, outNames, outTypes);
}
}
if (!found) {
throw new RuntimeException(
"no operation "
+ operationName
+ " was found in port type "
+ portType.getQName());
}
System.out.println("Executing operation " + operationName);
Object ret = call.invoke(inputs.toArray());
Map outputs = call.getOutputParams();
HashMap map = new HashMap();
for (int pos = 0; pos < outNames.length; ++pos) {
String name = outNames[pos];
Object value = outputs.get(name);
if (value == null && pos == 0)
map.put(name, ret);
else
map.put(name, value);
}
return map;
}
private static void retrieveSignature(
List parts,
String[] names,
Class[] types) {
// get parts in correct order
for (int i = 0; i < names.length; ++i) {
Part part = (Part) parts.get(i);
names[i] = part.getName();
QName partType = part.getTypeName();
if (partType == null) {
throw new RuntimeException(
"part " + names[i] + " must have type name declared");
}
// only limited number of types is supported
// cheerfully ignoring schema namespace ...
String s = partType.getLocalPart();
if ("string".equals(s)) {
types[i] = String.class;
} else if ("double".equals(s)) {
types[i] = Integer.TYPE;
} else if ("float".equals(s)) {
types[i] = Float.TYPE;
} else if ("int".equals(s)) {
types[i] = Integer.TYPE;
} else if ("boolean".equals(s)) {
types[i] = Boolean.TYPE;
} else {
throw new RuntimeException(
"part type " + partType + " not supported in this sample");
}
}
}
public static Service selectService(
Definition def,
String serviceNS,
String serviceName)
throws Exception {
Map services = getAllItems(def, "Service");
QName serviceQName =
((serviceNS != null && serviceName != null)
? new QName(serviceNS, serviceName)
: null);
Service service =
(Service) getNamedItem(services, serviceQName, "Service");
return service;
}
public static PortType selectPortType(
Definition def,
String portTypeNS,
String portTypeName)
throws Exception {
Map portTypes = getAllItems(def, "PortType");
QName portTypeQName =
((portTypeNS != null && portTypeName != null)
? new QName(portTypeNS, portTypeName)
: null);
PortType portType =
(PortType) getNamedItem(portTypes, portTypeQName, "PortType");
return portType;
}
public static Port selectPort(
Map ports,
String portNS,
String portName)
throws Exception {
QName portQName =
((portNS != null && portName != null)
? new QName(portNS, portName)
: null);
Port port =
(Port) getNamedItem(ports, portQName, "Port");
return port;
}
public static Object getNamedItem(Map items, QName qname, String itemType)
throws Exception {
if (qname != null) {
Object item = items.get(qname);
if (item != null) {
return item;
} else {
throw new Exception(
itemType
+ " '"
+ qname
+ "' not found. Choices are: "
+ getCommaListFromQNameMap(items));
}
} else {
int size = items.size();
if (size == 1) {
Iterator valueIterator = items.values().iterator();
Object o = valueIterator.next();
return o;
} else if (size == 0) {
throw new Exception(
"WSDL document contains no " + itemType + "s.");
} else {
throw new Exception(
"Please specify a "
+ itemType
+ ". Choices are: "
+ getCommaListFromQNameMap(items));
}
}
}
private static String getCommaListFromQNameMap(Map qnameMap) {
StringBuffer strBuf = new StringBuffer("{");
Set keySet = qnameMap.keySet();
Iterator keyIterator = keySet.iterator();
int index = 0;
while (keyIterator.hasNext()) {
QName key = (QName) keyIterator.next();
strBuf.append((index > 0 ? ", " : "") + key);
index++;
}
strBuf.append("}");
return strBuf.toString();
}
public static void addDefinedItems(
Map fromItems,
String itemType,
Map toItems) {
if (fromItems != null) {
Iterator entryIterator = fromItems.entrySet().iterator();
if (itemType.equals("Message")) {
while (entryIterator.hasNext()) {
Map.Entry entry = (Map.Entry) entryIterator.next();
Message message = (Message) entry.getValue();
if (!message.isUndefined()) {
toItems.put(entry.getKey(), message);
}
}
} else if (itemType.equals("Operation")) {
while (entryIterator.hasNext()) {
Map.Entry entry = (Map.Entry) entryIterator.next();
Operation operation = (Operation) entry.getValue();
if (!operation.isUndefined()) {
toItems.put(entry.getKey(), operation);
}
}
} else if (itemType.equals("PortType")) {
while (entryIterator.hasNext()) {
Map.Entry entry = (Map.Entry) entryIterator.next();
PortType portType = (PortType) entry.getValue();
if (!portType.isUndefined()) {
toItems.put(entry.getKey(), portType);
}
}
} else if (itemType.equals("Binding")) {
while (entryIterator.hasNext()) {
Map.Entry entry = (Map.Entry) entryIterator.next();
Binding binding = (Binding) entry.getValue();
if (!binding.isUndefined()) {
toItems.put(entry.getKey(), binding);
}
}
} else if (itemType.equals("Service")) {
while (entryIterator.hasNext()) {
Map.Entry entry = (Map.Entry) entryIterator.next();
Service service = (Service) entry.getValue();
toItems.put(entry.getKey(), service);
}
}
}
}
private static void getAllItems(
Definition def,
String itemType,
Map toItems) {
Map items = null;
if (itemType.equals("PortType")) {
items = def.getPortTypes();
} else if (itemType.equals("Service")) {
items = def.getServices();
} else {
throw new IllegalArgumentException(
"Don't know how to find all " + itemType + "s.");
}
addDefinedItems(items, itemType, toItems);
Map imports = def.getImports();
if (imports != null) {
Iterator valueIterator = imports.values().iterator();
while (valueIterator.hasNext()) {
List importList = (List) valueIterator.next();
if (importList != null) {
Iterator importIterator = importList.iterator();
while (importIterator.hasNext()) {
Import tempImport = (Import) importIterator.next();
if (tempImport != null) {
Definition importedDef = tempImport.getDefinition();
if (importedDef != null) {
getAllItems(importedDef, itemType, toItems);
}
}
}
}
}
}
}
public static Map getAllItems(Definition def, String itemType) {
Map ret = new HashMap();
getAllItems(def, itemType, ret);
return ret;
}
}
1.1 xml-axis/java/samples/client/readme
Index: readme
===================================================================
To run the DynamicInvoker sample, you must do the following:
1. Set up your CLASSPATH.
2. Compile the code.
3. Run the sample.
1. Set up your CLASSPATH.
The CLASSPATH must contain: an XML parser (ie., Xerces), JUnit
(www.junit.org), all the jars in the lib directory, and the directory
containing the samples subdirectory.
2. Compile the code.
a. Now you can change directory to samples/client
b. And compile the sample: javac *.java
3. Run the sample.
Finally, to run the client, run:
java samples.client.DynamicInvoker http://www.xmethods.net/sd/2001/TemperatureService.wsdl getTemp 02067
java samples.client.DynamicInvoker http://services.xmethods.net/soap/urn:xmethods-delayed-quotes.wsdl getQuote IBM