You are viewing a plain text version of this content. The canonical link for it is here.
Posted to axis-cvs@ws.apache.org by sa...@apache.org on 2005/12/20 19:40:04 UTC
svn commit: r358066 -
/webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/deployment/AxisServiceBuilder.java
Author: sanka
Date: Tue Dec 20 10:39:48 2005
New Revision: 358066
URL: http://svn.apache.org/viewcvs?rev=358066&view=rev
Log:
Added: AxisServiceBuilder which builds an AxisService object using a WSDL document which is fed as an InputStream or a javax.wsdl.Definition
Added:
webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/deployment/AxisServiceBuilder.java
Added: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/deployment/AxisServiceBuilder.java
URL: http://svn.apache.org/viewcvs/webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/deployment/AxisServiceBuilder.java?rev=358066&view=auto
==============================================================================
--- webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/deployment/AxisServiceBuilder.java (added)
+++ webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/deployment/AxisServiceBuilder.java Tue Dec 20 10:39:48 2005
@@ -0,0 +1,205 @@
+/*
+ * 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.axis2.deployment;
+
+import java.io.FileInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.Iterator;
+import java.util.Map;
+
+import javax.wsdl.Binding;
+import javax.wsdl.BindingOperation;
+import javax.wsdl.Definition;
+import javax.wsdl.Input;
+import javax.wsdl.Message;
+import javax.wsdl.Operation;
+import javax.wsdl.Output;
+import javax.wsdl.Port;
+import javax.wsdl.Service;
+import javax.wsdl.Types;
+import javax.wsdl.WSDLException;
+import javax.wsdl.extensions.ExtensibilityElement;
+import javax.wsdl.extensions.schema.Schema;
+import javax.wsdl.extensions.soap.SOAPBinding;
+import javax.wsdl.factory.WSDLFactory;
+import javax.wsdl.xml.WSDLReader;
+import javax.xml.namespace.QName;
+import javax.xml.parsers.ParserConfigurationException;
+
+import org.apache.axis2.AxisFault;
+import org.apache.axis2.description.AxisMessage;
+import org.apache.axis2.description.AxisOperation;
+import org.apache.axis2.description.AxisOperationFactory;
+import org.apache.axis2.description.AxisService;
+import org.apache.axis2.util.XMLUtils;
+import org.apache.ws.commons.schema.XmlSchema;
+import org.apache.ws.commons.schema.XmlSchemaCollection;
+import org.apache.wsdl.WSDLConstants;
+import org.apache.wsdl.impl.WSDLProcessingException;
+import org.w3c.dom.Document;
+import org.w3c.dom.Element;
+import org.xml.sax.SAXException;
+
+/**
+ * AxisServiceBuilder builds an AxisService using a WSDL document which is feed
+ * as a javax.wsdl.Definition or as an InputStream. If there are multiple
+ * javax.wsdl.Service elements in the WSDL, the first is picked.
+ *
+ * @author Sanka Samaranayake (sanka@apache.org)
+ */
+public class AxisServiceBuilder {
+
+ public AxisService getAxisService(InputStream wsdlInputStream)
+ throws WSDLException {
+ WSDLReader reader = WSDLFactory.newInstance().newWSDLReader();
+ reader.setFeature("javax.wsdl.importDocuments", true);
+
+ Document doc;
+
+ try {
+ doc = XMLUtils.newDocument(wsdlInputStream);
+
+ } catch (ParserConfigurationException e) {
+ throw new WSDLException(WSDLException.PARSER_ERROR,
+ "Parser Configuration Error", e);
+
+ } catch (SAXException e) {
+ throw new WSDLException(WSDLException.PARSER_ERROR,
+ "Parser SAX Error", e);
+
+ } catch (IOException e) {
+ throw new WSDLException(WSDLException.INVALID_WSDL, "IO Error", e);
+ }
+
+ Definition wsdlDefinition = reader.readWSDL(null, doc);
+ return getAxisService(wsdlDefinition);
+ }
+
+ public AxisService getAxisService(Definition definition)
+ throws WSDLProcessingException {
+
+ AxisService axisService = new AxisService();
+ Map services = definition.getServices();
+
+ if (services.isEmpty()) {
+ throw new WSDLProcessingException("no Service element is found");
+ }
+
+ Iterator serviceIterator = services.values().iterator();
+ Service service = (Service) serviceIterator.next();
+
+ // setting the name
+ axisService.setName(service.getQName().getLocalPart());
+
+ // setting the schema
+ Types types = definition.getTypes();
+ Iterator extElements = types.getExtensibilityElements().iterator();
+
+ ExtensibilityElement extElement;
+
+ while (extElements.hasNext()) {
+ extElement = (ExtensibilityElement) extElements.next();
+
+ if (extElement instanceof Schema) {
+ Element schemaElement = ((Schema) extElement).getElement();
+ axisService.setSchema(getXMLSchema(schemaElement));
+ }
+ }
+
+ // getting the port of the service with SOAP binding
+ Port port = getSOAPBindingPort(service);
+
+ if (port == null) {
+ throw new WSDLProcessingException("no SOAPBinding Port found");
+ }
+
+ Binding binding = port.getBinding();
+ Iterator bindingOperations = binding.getBindingOperations().iterator();
+
+ while (bindingOperations.hasNext()) {
+ BindingOperation bindingOperation = (BindingOperation) bindingOperations
+ .next();
+ Operation operation = bindingOperation.getOperation();
+
+ try {
+ AxisOperation axisOperation = AxisOperationFactory
+ .getAxisOperation(getMessageExchangePattern(bindingOperation));
+
+ // Input
+ Input input = operation.getInput();
+ AxisMessage inAxisMsg = axisOperation
+ .getMessage(WSDLConstants.MESSAGE_LABEL_IN_VALUE);
+ Message inMsg = input.getMessage();
+ inAxisMsg.setElementQName(inMsg.getQName());
+
+ // Output
+ Output output = operation.getOutput();
+
+ if (output != null) {
+ AxisMessage outAxisMsg = axisOperation
+ .getMessage(WSDLConstants.MESSAGE_LABEL_OUT_VALUE);
+ Message outMsg = output.getMessage();
+ outAxisMsg.setElementQName(outMsg.getQName());
+ }
+
+ axisService.addOperation(axisOperation);
+
+ } catch (AxisFault axisFault) {
+
+ throw new WSDLProcessingException(axisFault.getMessage());
+ }
+ }
+
+ return axisService;
+ }
+
+ private Port getSOAPBindingPort(Service service) {
+ Iterator ports = service.getPorts().values().iterator();
+ Port port;
+ Binding binding;
+
+ while (ports.hasNext()) {
+ port = (Port) ports.next();
+ binding = port.getBinding();
+ Iterator extElements = binding.getExtensibilityElements()
+ .iterator();
+
+ while (extElements.hasNext()) {
+
+ if (extElements.next() instanceof SOAPBinding) {
+ return port;
+ }
+ }
+ }
+ return null;
+ }
+
+ private int getMessageExchangePattern(BindingOperation bindingOperation) {
+
+ if (bindingOperation.getBindingOutput() == null) {
+ return WSDLConstants.MEP_CONSTANT_IN_ONLY;
+
+ } else {
+ return WSDLConstants.MEP_CONSTANT_IN_OUT;
+ }
+ }
+
+ private XmlSchema getXMLSchema(Element element) {
+ return (new XmlSchemaCollection()).read(element);
+ }
+}