src/share/jaxws_classes/com/sun/xml/internal/ws/model/wsdl/WSDLBoundOperationImpl.java

Thu, 31 Aug 2017 15:18:52 +0800

author
aoqi
date
Thu, 31 Aug 2017 15:18:52 +0800
changeset 637
9c07ef4934dd
parent 408
b0610cd08440
parent 0
373ffda63c9a
permissions
-rw-r--r--

merge

aoqi@0 1 /*
aoqi@0 2 * Copyright (c) 1997, 2013, Oracle and/or its affiliates. All rights reserved.
aoqi@0 3 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
aoqi@0 4 *
aoqi@0 5 * This code is free software; you can redistribute it and/or modify it
aoqi@0 6 * under the terms of the GNU General Public License version 2 only, as
aoqi@0 7 * published by the Free Software Foundation. Oracle designates this
aoqi@0 8 * particular file as subject to the "Classpath" exception as provided
aoqi@0 9 * by Oracle in the LICENSE file that accompanied this code.
aoqi@0 10 *
aoqi@0 11 * This code is distributed in the hope that it will be useful, but WITHOUT
aoqi@0 12 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
aoqi@0 13 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
aoqi@0 14 * version 2 for more details (a copy is included in the LICENSE file that
aoqi@0 15 * accompanied this code).
aoqi@0 16 *
aoqi@0 17 * You should have received a copy of the GNU General Public License version
aoqi@0 18 * 2 along with this work; if not, write to the Free Software Foundation,
aoqi@0 19 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
aoqi@0 20 *
aoqi@0 21 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
aoqi@0 22 * or visit www.oracle.com if you need additional information or have any
aoqi@0 23 * questions.
aoqi@0 24 */
aoqi@0 25
aoqi@0 26 package com.sun.xml.internal.ws.model.wsdl;
aoqi@0 27
aoqi@0 28 import com.sun.istack.internal.Nullable;
aoqi@0 29 import com.sun.istack.internal.NotNull;
aoqi@0 30 import com.sun.xml.internal.ws.api.model.ParameterBinding;
aoqi@0 31 import com.sun.xml.internal.ws.api.model.wsdl.*;
aoqi@0 32 import com.sun.xml.internal.ws.api.model.wsdl.editable.EditableWSDLBoundFault;
aoqi@0 33 import com.sun.xml.internal.ws.api.model.wsdl.editable.EditableWSDLBoundOperation;
aoqi@0 34 import com.sun.xml.internal.ws.api.model.wsdl.editable.EditableWSDLBoundPortType;
aoqi@0 35 import com.sun.xml.internal.ws.api.model.wsdl.editable.EditableWSDLMessage;
aoqi@0 36 import com.sun.xml.internal.ws.api.model.wsdl.editable.EditableWSDLModel;
aoqi@0 37 import com.sun.xml.internal.ws.api.model.wsdl.editable.EditableWSDLOperation;
aoqi@0 38 import com.sun.xml.internal.ws.api.model.wsdl.editable.EditableWSDLPart;
aoqi@0 39 import com.sun.xml.internal.ws.model.RuntimeModeler;
aoqi@0 40
aoqi@0 41 import javax.jws.WebParam.Mode;
aoqi@0 42 import javax.jws.soap.SOAPBinding.Style;
aoqi@0 43 import javax.xml.namespace.QName;
aoqi@0 44 import javax.xml.stream.XMLStreamReader;
aoqi@0 45
aoqi@0 46 import java.util.*;
aoqi@0 47
aoqi@0 48 /**
aoqi@0 49 * Implementation of {@link WSDLBoundOperation}
aoqi@0 50 *
aoqi@0 51 * @author Vivek Pandey
aoqi@0 52 */
aoqi@0 53 public final class WSDLBoundOperationImpl extends AbstractExtensibleImpl implements EditableWSDLBoundOperation {
aoqi@0 54 private final QName name;
aoqi@0 55
aoqi@0 56 // map of wsdl:part to the binding
aoqi@0 57 private final Map<String, ParameterBinding> inputParts;
aoqi@0 58 private final Map<String, ParameterBinding> outputParts;
aoqi@0 59 private final Map<String, ParameterBinding> faultParts;
aoqi@0 60 private final Map<String, String> inputMimeTypes;
aoqi@0 61 private final Map<String, String> outputMimeTypes;
aoqi@0 62 private final Map<String, String> faultMimeTypes;
aoqi@0 63
aoqi@0 64 private boolean explicitInputSOAPBodyParts = false;
aoqi@0 65 private boolean explicitOutputSOAPBodyParts = false;
aoqi@0 66 private boolean explicitFaultSOAPBodyParts = false;
aoqi@0 67
aoqi@0 68 private Boolean emptyInputBody;
aoqi@0 69 private Boolean emptyOutputBody;
aoqi@0 70 private Boolean emptyFaultBody;
aoqi@0 71
aoqi@0 72 private final Map<String, EditableWSDLPart> inParts;
aoqi@0 73 private final Map<String, EditableWSDLPart> outParts;
aoqi@0 74 private final List<EditableWSDLBoundFault> wsdlBoundFaults;
aoqi@0 75 private EditableWSDLOperation operation;
aoqi@0 76 private String soapAction;
aoqi@0 77 private ANONYMOUS anonymous;
aoqi@0 78
aoqi@0 79 private final EditableWSDLBoundPortType owner;
aoqi@0 80
aoqi@0 81 /**
aoqi@0 82 *
aoqi@0 83 * @param name wsdl:operation name qualified value
aoqi@0 84 */
aoqi@0 85 public WSDLBoundOperationImpl(XMLStreamReader xsr, EditableWSDLBoundPortType owner, QName name) {
aoqi@0 86 super(xsr);
aoqi@0 87 this.name = name;
aoqi@0 88 inputParts = new HashMap<String, ParameterBinding>();
aoqi@0 89 outputParts = new HashMap<String, ParameterBinding>();
aoqi@0 90 faultParts = new HashMap<String, ParameterBinding>();
aoqi@0 91 inputMimeTypes = new HashMap<String, String>();
aoqi@0 92 outputMimeTypes = new HashMap<String, String>();
aoqi@0 93 faultMimeTypes = new HashMap<String, String>();
aoqi@0 94 inParts = new HashMap<String, EditableWSDLPart>();
aoqi@0 95 outParts = new HashMap<String, EditableWSDLPart>();
aoqi@0 96 wsdlBoundFaults = new ArrayList<EditableWSDLBoundFault>();
aoqi@0 97 this.owner = owner;
aoqi@0 98 }
aoqi@0 99
aoqi@0 100 @Override
aoqi@0 101 public QName getName(){
aoqi@0 102 return name;
aoqi@0 103 }
aoqi@0 104
aoqi@0 105 @Override
aoqi@0 106 public String getSOAPAction() {
aoqi@0 107 return soapAction;
aoqi@0 108 }
aoqi@0 109
aoqi@0 110 public void setSoapAction(String soapAction) {
aoqi@0 111 this.soapAction = soapAction!=null?soapAction:"";
aoqi@0 112 }
aoqi@0 113
aoqi@0 114 @Override
aoqi@0 115 public EditableWSDLPart getPart(String partName, Mode mode) {
aoqi@0 116 if(mode==Mode.IN){
aoqi@0 117 return inParts.get(partName);
aoqi@0 118 }else if(mode==Mode.OUT){
aoqi@0 119 return outParts.get(partName);
aoqi@0 120 }
aoqi@0 121 return null;
aoqi@0 122 }
aoqi@0 123
aoqi@0 124 public void addPart(EditableWSDLPart part, Mode mode){
aoqi@0 125 if(mode==Mode.IN)
aoqi@0 126 inParts.put(part.getName(), part);
aoqi@0 127 else if(mode==Mode.OUT)
aoqi@0 128 outParts.put(part.getName(), part);
aoqi@0 129 }
aoqi@0 130
aoqi@0 131 /**
aoqi@0 132 * Map of wsdl:input part name and the binding as {@link ParameterBinding}
aoqi@0 133 *
aoqi@0 134 * @return empty Map if there is no parts
aoqi@0 135 */
aoqi@0 136 public Map<String, ParameterBinding> getInputParts() {
aoqi@0 137 return inputParts;
aoqi@0 138 }
aoqi@0 139
aoqi@0 140 /**
aoqi@0 141 * Map of wsdl:output part name and the binding as {@link ParameterBinding}
aoqi@0 142 *
aoqi@0 143 * @return empty Map if there is no parts
aoqi@0 144 */
aoqi@0 145 public Map<String, ParameterBinding> getOutputParts() {
aoqi@0 146 return outputParts;
aoqi@0 147 }
aoqi@0 148
aoqi@0 149 /**
aoqi@0 150 * Map of wsdl:fault part name and the binding as {@link ParameterBinding}
aoqi@0 151 *
aoqi@0 152 * @return empty Map if there is no parts
aoqi@0 153 */
aoqi@0 154 public Map<String, ParameterBinding> getFaultParts() {
aoqi@0 155 return faultParts;
aoqi@0 156 }
aoqi@0 157
aoqi@0 158 // TODO: what's the difference between this and inputParts/outputParts?
aoqi@0 159 @Override
aoqi@0 160 public Map<String, ? extends EditableWSDLPart> getInParts() {
aoqi@0 161 return Collections.<String, EditableWSDLPart>unmodifiableMap(inParts);
aoqi@0 162 }
aoqi@0 163
aoqi@0 164 @Override
aoqi@0 165 public Map<String, ? extends EditableWSDLPart> getOutParts() {
aoqi@0 166 return Collections.<String, EditableWSDLPart>unmodifiableMap(outParts);
aoqi@0 167 }
aoqi@0 168
aoqi@0 169 @NotNull
aoqi@0 170 @Override
aoqi@0 171 public List<? extends EditableWSDLBoundFault> getFaults() {
aoqi@0 172 return wsdlBoundFaults;
aoqi@0 173 }
aoqi@0 174
aoqi@0 175 public void addFault(@NotNull EditableWSDLBoundFault fault){
aoqi@0 176 wsdlBoundFaults.add(fault);
aoqi@0 177 }
aoqi@0 178
aoqi@0 179
aoqi@0 180 /**
aoqi@0 181 * Gets {@link ParameterBinding} for a given wsdl part in wsdl:input
aoqi@0 182 *
aoqi@0 183 * @param part Name of wsdl:part, must be non-null
aoqi@0 184 * @return null if the part is not found.
aoqi@0 185 */
aoqi@0 186 public ParameterBinding getInputBinding(String part){
aoqi@0 187 if(emptyInputBody == null){
aoqi@0 188 if(inputParts.get(" ") != null)
aoqi@0 189 emptyInputBody = true;
aoqi@0 190 else
aoqi@0 191 emptyInputBody = false;
aoqi@0 192 }
aoqi@0 193 ParameterBinding block = inputParts.get(part);
aoqi@0 194 if(block == null){
aoqi@0 195 if(explicitInputSOAPBodyParts || emptyInputBody)
aoqi@0 196 return ParameterBinding.UNBOUND;
aoqi@0 197 return ParameterBinding.BODY;
aoqi@0 198 }
aoqi@0 199
aoqi@0 200 return block;
aoqi@0 201 }
aoqi@0 202
aoqi@0 203 /**
aoqi@0 204 * Gets {@link ParameterBinding} for a given wsdl part in wsdl:output
aoqi@0 205 *
aoqi@0 206 * @param part Name of wsdl:part, must be non-null
aoqi@0 207 * @return null if the part is not found.
aoqi@0 208 */
aoqi@0 209 public ParameterBinding getOutputBinding(String part){
aoqi@0 210 if(emptyOutputBody == null){
aoqi@0 211 if(outputParts.get(" ") != null)
aoqi@0 212 emptyOutputBody = true;
aoqi@0 213 else
aoqi@0 214 emptyOutputBody = false;
aoqi@0 215 }
aoqi@0 216 ParameterBinding block = outputParts.get(part);
aoqi@0 217 if(block == null){
aoqi@0 218 if(explicitOutputSOAPBodyParts || emptyOutputBody)
aoqi@0 219 return ParameterBinding.UNBOUND;
aoqi@0 220 return ParameterBinding.BODY;
aoqi@0 221 }
aoqi@0 222
aoqi@0 223 return block;
aoqi@0 224 }
aoqi@0 225
aoqi@0 226 /**
aoqi@0 227 * Gets {@link ParameterBinding} for a given wsdl part in wsdl:fault
aoqi@0 228 *
aoqi@0 229 * @param part Name of wsdl:part, must be non-null
aoqi@0 230 * @return null if the part is not found.
aoqi@0 231 */
aoqi@0 232 public ParameterBinding getFaultBinding(String part){
aoqi@0 233 if(emptyFaultBody == null){
aoqi@0 234 if(faultParts.get(" ") != null)
aoqi@0 235 emptyFaultBody = true;
aoqi@0 236 else
aoqi@0 237 emptyFaultBody = false;
aoqi@0 238 }
aoqi@0 239 ParameterBinding block = faultParts.get(part);
aoqi@0 240 if(block == null){
aoqi@0 241 if(explicitFaultSOAPBodyParts || emptyFaultBody)
aoqi@0 242 return ParameterBinding.UNBOUND;
aoqi@0 243 return ParameterBinding.BODY;
aoqi@0 244 }
aoqi@0 245
aoqi@0 246 return block;
aoqi@0 247 }
aoqi@0 248
aoqi@0 249 /**
aoqi@0 250 * Gets the MIME type for a given wsdl part in wsdl:input
aoqi@0 251 *
aoqi@0 252 * @param part Name of wsdl:part, must be non-null
aoqi@0 253 * @return null if the part is not found.
aoqi@0 254 */
aoqi@0 255 public String getMimeTypeForInputPart(String part){
aoqi@0 256 return inputMimeTypes.get(part);
aoqi@0 257 }
aoqi@0 258
aoqi@0 259 /**
aoqi@0 260 * Gets the MIME type for a given wsdl part in wsdl:output
aoqi@0 261 *
aoqi@0 262 * @param part Name of wsdl:part, must be non-null
aoqi@0 263 * @return null if the part is not found.
aoqi@0 264 */
aoqi@0 265 public String getMimeTypeForOutputPart(String part){
aoqi@0 266 return outputMimeTypes.get(part);
aoqi@0 267 }
aoqi@0 268
aoqi@0 269 /**
aoqi@0 270 * Gets the MIME type for a given wsdl part in wsdl:fault
aoqi@0 271 *
aoqi@0 272 * @param part Name of wsdl:part, must be non-null
aoqi@0 273 * @return null if the part is not found.
aoqi@0 274 */
aoqi@0 275 public String getMimeTypeForFaultPart(String part){
aoqi@0 276 return faultMimeTypes.get(part);
aoqi@0 277 }
aoqi@0 278
aoqi@0 279 @Override
aoqi@0 280 public EditableWSDLOperation getOperation() {
aoqi@0 281 return operation;
aoqi@0 282 }
aoqi@0 283
aoqi@0 284
aoqi@0 285 @Override
aoqi@0 286 public EditableWSDLBoundPortType getBoundPortType() {
aoqi@0 287 return owner;
aoqi@0 288 }
aoqi@0 289
aoqi@0 290 public void setInputExplicitBodyParts(boolean b) {
aoqi@0 291 explicitInputSOAPBodyParts = b;
aoqi@0 292 }
aoqi@0 293
aoqi@0 294 public void setOutputExplicitBodyParts(boolean b) {
aoqi@0 295 explicitOutputSOAPBodyParts = b;
aoqi@0 296 }
aoqi@0 297
aoqi@0 298 public void setFaultExplicitBodyParts(boolean b) {
aoqi@0 299 explicitFaultSOAPBodyParts = b;
aoqi@0 300 }
aoqi@0 301
aoqi@0 302 private Style style = Style.DOCUMENT;
aoqi@0 303 public void setStyle(Style style){
aoqi@0 304 this.style = style;
aoqi@0 305 }
aoqi@0 306
aoqi@0 307 @Override
aoqi@0 308 public @Nullable QName getRequestPayloadName() {
aoqi@0 309 if (emptyRequestPayload)
aoqi@0 310 return null;
aoqi@0 311
aoqi@0 312 if (requestPayloadName != null)
aoqi@0 313 return requestPayloadName;
aoqi@0 314
aoqi@0 315 if(style.equals(Style.RPC)){
aoqi@0 316 String ns = getRequestNamespace() != null ? getRequestNamespace() : name.getNamespaceURI();
aoqi@0 317 requestPayloadName = new QName(ns, name.getLocalPart());
aoqi@0 318 return requestPayloadName;
aoqi@0 319 }else{
aoqi@0 320 QName inMsgName = operation.getInput().getMessage().getName();
aoqi@0 321 EditableWSDLMessage message = messages.get(inMsgName);
aoqi@0 322 for(EditableWSDLPart part:message.parts()){
aoqi@0 323 ParameterBinding binding = getInputBinding(part.getName());
aoqi@0 324 if(binding.isBody()){
aoqi@0 325 requestPayloadName = part.getDescriptor().name();
aoqi@0 326 return requestPayloadName;
aoqi@0 327 }
aoqi@0 328 }
aoqi@0 329
aoqi@0 330 //Its empty payload
aoqi@0 331 emptyRequestPayload = true;
aoqi@0 332 }
aoqi@0 333 //empty body
aoqi@0 334 return null;
aoqi@0 335 }
aoqi@0 336
aoqi@0 337 @Override
aoqi@0 338 public @Nullable QName getResponsePayloadName() {
aoqi@0 339 if (emptyResponsePayload)
aoqi@0 340 return null;
aoqi@0 341
aoqi@0 342 if (responsePayloadName != null)
aoqi@0 343 return responsePayloadName;
aoqi@0 344
aoqi@0 345 if(style.equals(Style.RPC)){
aoqi@0 346 String ns = getResponseNamespace() != null ? getResponseNamespace() : name.getNamespaceURI();
aoqi@0 347 responsePayloadName = new QName(ns, name.getLocalPart()+"Response");
aoqi@0 348 return responsePayloadName;
aoqi@0 349 }else{
aoqi@0 350 QName outMsgName = operation.getOutput().getMessage().getName();
aoqi@0 351 EditableWSDLMessage message = messages.get(outMsgName);
aoqi@0 352 for(EditableWSDLPart part:message.parts()){
aoqi@0 353 ParameterBinding binding = getOutputBinding(part.getName());
aoqi@0 354 if(binding.isBody()){
aoqi@0 355 responsePayloadName = part.getDescriptor().name();
aoqi@0 356 return responsePayloadName;
aoqi@0 357 }
aoqi@0 358 }
aoqi@0 359
aoqi@0 360 //Its empty payload
aoqi@0 361 emptyResponsePayload = true;
aoqi@0 362 }
aoqi@0 363 //empty body
aoqi@0 364 return null;
aoqi@0 365 }
aoqi@0 366
aoqi@0 367
aoqi@0 368 private String reqNamespace;
aoqi@0 369 private String respNamespace;
aoqi@0 370
aoqi@0 371 /**
aoqi@0 372 * For rpclit gives namespace value on soapbinding:body@namespace
aoqi@0 373 *
aoqi@0 374 * @return non-null for rpclit and null for doclit
aoqi@0 375 * @see RuntimeModeler#processRpcMethod(JavaMethodImpl, String, String, Method)
aoqi@0 376 */
aoqi@0 377 @Override
aoqi@0 378 public String getRequestNamespace(){
aoqi@0 379 return (reqNamespace != null)?reqNamespace:name.getNamespaceURI();
aoqi@0 380 }
aoqi@0 381
aoqi@0 382 public void setRequestNamespace(String ns){
aoqi@0 383 reqNamespace = ns;
aoqi@0 384 }
aoqi@0 385
aoqi@0 386 /**
aoqi@0 387 * For rpclit gives namespace value on soapbinding:body@namespace
aoqi@0 388 *
aoqi@0 389 * @return non-null for rpclit and null for doclit
aoqi@0 390 * @see RuntimeModeler#processRpcMethod(JavaMethodImpl, String, String, Method)
aoqi@0 391 */
aoqi@0 392 @Override
aoqi@0 393 public String getResponseNamespace(){
aoqi@0 394 return (respNamespace!=null)?respNamespace:name.getNamespaceURI();
aoqi@0 395 }
aoqi@0 396
aoqi@0 397 public void setResponseNamespace(String ns){
aoqi@0 398 respNamespace = ns;
aoqi@0 399 }
aoqi@0 400
aoqi@0 401 EditableWSDLBoundPortType getOwner(){
aoqi@0 402 return owner;
aoqi@0 403 }
aoqi@0 404
aoqi@0 405 private QName requestPayloadName;
aoqi@0 406 private QName responsePayloadName;
aoqi@0 407 private boolean emptyRequestPayload;
aoqi@0 408 private boolean emptyResponsePayload;
aoqi@0 409 private Map<QName, ? extends EditableWSDLMessage> messages;
aoqi@0 410
aoqi@0 411 public void freeze(EditableWSDLModel parent) {
aoqi@0 412 messages = parent.getMessages();
aoqi@0 413 operation = owner.getPortType().get(name.getLocalPart());
aoqi@0 414 for(EditableWSDLBoundFault bf : wsdlBoundFaults){
aoqi@0 415 bf.freeze(this);
aoqi@0 416 }
aoqi@0 417 }
aoqi@0 418
aoqi@0 419 public void setAnonymous(ANONYMOUS anonymous) {
aoqi@0 420 this.anonymous = anonymous;
aoqi@0 421 }
aoqi@0 422
aoqi@0 423 /**
aoqi@0 424 * @inheritDoc
aoqi@0 425 */
aoqi@0 426 @Override
aoqi@0 427 public ANONYMOUS getAnonymous() {
aoqi@0 428 return anonymous;
aoqi@0 429 }
aoqi@0 430 }

mercurial