|
Apache CXF example source code file (WSDLToSoapProcessor.java)
The Apache CXF WSDLToSoapProcessor.java source code/** * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you 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.cxf.tools.misc.processor; import java.io.IOException; import java.io.Writer; import java.util.Iterator; import java.util.List; import java.util.Map; import javax.wsdl.Binding; import javax.wsdl.BindingFault; import javax.wsdl.BindingInput; import javax.wsdl.BindingOperation; import javax.wsdl.BindingOutput; import javax.wsdl.Fault; import javax.wsdl.Input; import javax.wsdl.Operation; import javax.wsdl.Output; import javax.wsdl.Part; import javax.wsdl.PortType; import javax.wsdl.WSDLException; import javax.wsdl.xml.WSDLWriter; import javax.xml.namespace.QName; import org.apache.cxf.common.WSDLConstants; import org.apache.cxf.common.i18n.Message; import org.apache.cxf.tools.common.ToolConstants; import org.apache.cxf.tools.common.ToolException; import org.apache.cxf.tools.common.extensions.soap.SoapBinding; import org.apache.cxf.tools.common.extensions.soap.SoapBody; import org.apache.cxf.tools.common.extensions.soap.SoapFault; import org.apache.cxf.tools.common.extensions.soap.SoapOperation; import org.apache.cxf.tools.util.SOAPBindingUtil; public class WSDLToSoapProcessor extends AbstractWSDLToProcessor { private static final String NEW_FILE_NAME_MODIFIER = "-soapbinding"; private Map portTypes; private PortType portType; private Binding binding; public void process() throws ToolException { init(); validate(); doAppendBinding(); } private boolean isSOAP12() { return env.optionSet(ToolConstants.CFG_SOAP12); } private void validate() throws ToolException { if (isBindingExisted()) { Message msg = new Message("BINDING_ALREADY_EXIST", LOG); throw new ToolException(msg); } if (!isPortTypeExisted()) { Message msg = new Message("PORTTYPE_NOT_EXIST", LOG); throw new ToolException(msg); } if (!nameSpaceCheck()) { Message msg = new Message("SOAPBINDING_STYLE_NOT_PROVIDED", LOG); throw new ToolException(msg); } if (WSDLConstants.RPC.equalsIgnoreCase((String)env.get(ToolConstants.CFG_STYLE))) { Iterator it = portType.getOperations().iterator(); while (it.hasNext()) { Operation op = (Operation)it.next(); Input input = op.getInput(); if (input != null && input.getMessage() != null) { Iterator itParts = input.getMessage().getParts().values().iterator(); while (itParts.hasNext()) { Part part = (Part)itParts.next(); if (part.getTypeName() == null || "".equals(part.getTypeName().toString())) { Message msg = new Message("RPC_PART_ILLEGAL", LOG, new Object[] {part.getName()}); throw new ToolException(msg); } } } Output output = op.getOutput(); if (output != null && output.getMessage() != null) { Iterator itParts = output.getMessage().getParts().values().iterator(); while (itParts.hasNext()) { Part part = (Part)itParts.next(); if (part.getTypeName() == null || "".equals(part.getTypeName().toString())) { Message msg = new Message("RPC_PART_ILLEGAL", LOG, new Object[] {part.getName()}); throw new ToolException(msg); } } } } } } private boolean isPortTypeExisted() { portTypes = wsdlDefinition.getPortTypes(); if (portTypes == null) { return false; } Iterator it = portTypes.keySet().iterator(); while (it.hasNext()) { QName existPortQName = (QName)it.next(); String existPortName = existPortQName.getLocalPart(); if (existPortName.equals(env.get(ToolConstants.CFG_PORTTYPE))) { portType = (PortType)portTypes.get(existPortQName); break; } } return (portType == null) ? false : true; } private boolean isBindingExisted() { Map bindings = wsdlDefinition.getBindings(); if (bindings == null) { return false; } Iterator it = bindings.keySet().iterator(); while (it.hasNext()) { QName existBindingQName = (QName)it.next(); String existBindingName = existBindingQName.getLocalPart(); String bindingName = (String)env.get(ToolConstants.CFG_BINDING); if (bindingName.equals(existBindingName)) { binding = (Binding)bindings.get(existBindingQName); } } return (binding == null) ? false : true; } private boolean nameSpaceCheck() { if (WSDLConstants.RPC.equalsIgnoreCase((String)env.get(ToolConstants.CFG_STYLE)) && !env.optionSet(ToolConstants.CFG_NAMESPACE)) { return false; } return true; } protected void init() throws ToolException { parseWSDL((String)env.get(ToolConstants.CFG_WSDLURL)); } private void doAppendBinding() throws ToolException { if (binding == null) { binding = wsdlDefinition.createBinding(); binding.setQName(new QName(wsdlDefinition.getTargetNamespace(), (String)env.get(ToolConstants.CFG_BINDING))); binding.setUndefined(false); binding.setPortType(portType); } setSoapBindingExtElement(); addBindingOperation(); wsdlDefinition.addBinding(binding); WSDLWriter wsdlWriter = wsdlFactory.newWSDLWriter(); Writer outputWriter = getOutputWriter(NEW_FILE_NAME_MODIFIER); try { wsdlWriter.writeWSDL(wsdlDefinition, outputWriter); } catch (WSDLException wse) { Message msg = new Message("FAIL_TO_WRITE_WSDL", LOG, wse.getMessage()); throw new ToolException(msg); } try { outputWriter.close(); } catch (IOException ioe) { Message msg = new Message("PORTTYPE_NOT_EXIST", LOG); throw new ToolException(msg); } } private void setSoapBindingExtElement() throws ToolException { if (extReg == null) { extReg = wsdlFactory.newPopulatedExtensionRegistry(); } SOAPBindingUtil.addSOAPNamespace(wsdlDefinition, isSOAP12()); SoapBinding soapBinding = null; try { soapBinding = SOAPBindingUtil.createSoapBinding(extReg, isSOAP12()); } catch (WSDLException wse) { Message msg = new Message("FAIL_TO_CREATE_SOAPBINDING", LOG); throw new ToolException(msg, wse); } soapBinding.setStyle((String)env.get(ToolConstants.CFG_STYLE)); binding.addExtensibilityElement(soapBinding); } @SuppressWarnings("unchecked") private void addBindingOperation() throws ToolException { /** * This method won't do unique operation name checking on portType The * WS-I Basic Profile[17] R2304 requires that operations within a * wsdl:portType have unique values for their name attribute so mapping * of WS-I compliant WSDLdescriptions will not generate Java interfaces * with overloaded methods. However, for backwards compatibility, JAX-WS * supports operation name overloading provided the overloading does not * cause conflicts (as specified in the Java Language Specification[25]) * in the mapped Java service endpoint interface declaration. */ List<Operation> ops = portType.getOperations(); for (Operation op : ops) { BindingOperation bindingOperation = wsdlDefinition.createBindingOperation(); setSoapOperationExtElement(bindingOperation); bindingOperation.setName(op.getName()); if (op.getInput() != null) { bindingOperation.setBindingInput(getBindingInput(op.getInput())); } if (op.getOutput() != null) { bindingOperation.setBindingOutput(getBindingOutput(op.getOutput())); } if (op.getFaults() != null && op.getFaults().size() > 0) { addSoapFaults(op, bindingOperation); } bindingOperation.setOperation(op); binding.addBindingOperation(bindingOperation); } } private void setSoapOperationExtElement(BindingOperation bo) throws ToolException { if (extReg == null) { extReg = wsdlFactory.newPopulatedExtensionRegistry(); } SoapOperation soapOperation = null; try { soapOperation = SOAPBindingUtil.createSoapOperation(extReg, isSOAP12()); } catch (WSDLException wse) { Message msg = new Message("FAIL_TO_CREATE_SOAPBINDING", LOG); throw new ToolException(msg, wse); } soapOperation.setStyle((String)env.get(ToolConstants.CFG_STYLE)); soapOperation.setSoapActionURI(""); bo.addExtensibilityElement(soapOperation); } private BindingInput getBindingInput(Input input) throws ToolException { BindingInput bi = wsdlDefinition.createBindingInput(); bi.setName(input.getName()); // As command line won't specify the details of body/header for message // parts // All input message's parts will be added into one soap body element bi.addExtensibilityElement(getSoapBody(BindingInput.class)); return bi; } private BindingOutput getBindingOutput(Output output) throws ToolException { BindingOutput bo = wsdlDefinition.createBindingOutput(); bo.setName(output.getName()); // As command line won't specify the details of body/header for message // parts // All output message's parts will be added into one soap body element bo.addExtensibilityElement(getSoapBody(BindingOutput.class)); return bo; } private SoapBody getSoapBody(Class parent) throws ToolException { if (extReg == null) { extReg = wsdlFactory.newPopulatedExtensionRegistry(); } SoapBody soapBody = null; try { soapBody = SOAPBindingUtil.createSoapBody(extReg, parent, isSOAP12()); } catch (WSDLException wse) { Message msg = new Message("FAIL_TO_CREATE_SOAPBINDING", LOG); throw new ToolException(msg, wse); } soapBody.setUse((String)env.get(ToolConstants.CFG_USE)); if (WSDLConstants.RPC.equalsIgnoreCase((String)env.get(ToolConstants.CFG_STYLE)) && env.optionSet(ToolConstants.CFG_NAMESPACE)) { soapBody.setNamespaceURI((String)env.get(ToolConstants.CFG_NAMESPACE)); } return soapBody; } private void addSoapFaults(Operation op, BindingOperation bindingOperation) throws ToolException { Map faults = op.getFaults(); Iterator it = faults.keySet().iterator(); while (it.hasNext()) { String key = (String)it.next(); Fault fault = (Fault)faults.get(key); BindingFault bf = wsdlDefinition.createBindingFault(); bf.setName(fault.getName()); setSoapFaultExtElement(bf); bindingOperation.addBindingFault(bf); } } private void setSoapFaultExtElement(BindingFault bf) throws ToolException { if (extReg == null) { extReg = wsdlFactory.newPopulatedExtensionRegistry(); } SoapFault soapFault = null; try { soapFault = SOAPBindingUtil.createSoapFault(extReg, isSOAP12()); } catch (WSDLException wse) { Message msg = new Message("FAIL_TO_CREATE_SOAPBINDING", LOG); throw new ToolException(msg, wse); } soapFault.setName(bf.getName()); soapFault.setUse((String)env.get(ToolConstants.CFG_USE)); if (WSDLConstants.RPC.equalsIgnoreCase((String)env.get(ToolConstants.CFG_STYLE)) && env.optionSet(ToolConstants.CFG_NAMESPACE)) { soapFault.setNamespaceURI((String)env.get(ToolConstants.CFG_NAMESPACE)); } bf.addExtensibilityElement(soapFault); } } Other Apache CXF examples (source code examples)Here is a short list of links related to this Apache CXF WSDLToSoapProcessor.java source code file: |
... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2021 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.