jdk8-mips64-public/jaxws: src/share/jaxws_classes/com/sun/xml/internal/ws/client/sei/StubHandler.java@9c07ef4934dd (annotated)

src/share/jaxws_classes/com/sun/xml/internal/ws/client/sei/StubHandler.java@9c07ef4934dd (annotated)

src/share/jaxws_classes/com/sun/xml/internal/ws/client/sei/StubHandler.java

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

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

merge

 /*
  * Copyright (c) 1997, 2012, Oracle and/or its affiliates. All rights reserved.
  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
  *
  * This code is free software; you can redistribute it and/or modify it
  * under the terms of the GNU General Public License version 2 only, as
  * published by the Free Software Foundation.  Oracle designates this
  * particular file as subject to the "Classpath" exception as provided
  * by Oracle in the LICENSE file that accompanied this code.
  *
  * This code is distributed in the hope that it will be useful, but WITHOUT
  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
  * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
  * version 2 for more details (a copy is included in the LICENSE file that
  * accompanied this code).
  *
  * You should have received a copy of the GNU General Public License version
  * 2 along with this work; if not, write to the Free Software Foundation,
  * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
  *
  * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
  * or visit www.oracle.com if you need additional information or have any
  * questions.
  */
 package com.sun.xml.internal.ws.client.sei;
 import com.oracle.webservices.internal.api.databinding.JavaCallInfo;
 import com.sun.xml.internal.ws.api.SOAPVersion;
 import com.sun.xml.internal.ws.api.databinding.ClientCallBridge;
 import com.sun.xml.internal.ws.api.message.Message;
 import com.sun.xml.internal.ws.api.message.MessageContextFactory;
 import com.sun.xml.internal.ws.api.message.Packet;
 import com.sun.xml.internal.ws.api.model.JavaMethod;
 import com.sun.xml.internal.ws.fault.SOAPFaultBuilder;
 import com.sun.xml.internal.ws.model.CheckedExceptionImpl;
 import com.sun.xml.internal.ws.model.JavaMethodImpl;
 import com.sun.xml.internal.ws.model.ParameterImpl;
 import com.sun.xml.internal.ws.model.WrapperParameter;
 import javax.xml.namespace.QName;
 import java.lang.reflect.Method;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 /**
  * {@link com.sun.xml.internal.ws.client.sei.MethodHandler} that handles synchronous method invocations.
  *  This is refactored from SEIMethodHandler.
  * <p>
  * This class mainly performs the following two tasks:
  * <ol>
  *  <li>Accepts Object[] that represents arguments for a Java method,
  *      and creates {@link com.sun.xml.internal.ws.message.jaxb.JAXBMessage} that represents a request message.
  *  <li>Takes a {@link com.sun.xml.internal.ws.api.message.Message} that represents a response,
  *      and extracts the return value (and updates {@link javax.xml.ws.Holder }s.)
  * </ol>
  *
  * <h2>Creating {@link com.sun.xml.internal.ws.message.jaxb.JAXBMessage }</h2>
  * <p>
  * At the construction time, we prepare {@link com.sun.xml.internal.ws.client.sei.BodyBuilder} and {@link com.sun.xml.internal.ws.client.sei.MessageFiller}s
  * that know how to move arguments into a {@link com.sun.xml.internal.ws.api.message.Message }.
  * Some arguments go to the payload, some go to headers, still others go to attachments.
  *
  * @author Kohsuke Kawaguchi
  * @author Jitendra Kotamraju
  * @author shih-chang.chen@oracle.com
  */
 public class StubHandler implements ClientCallBridge {
     // these objects together create a message from method parameters
     private final BodyBuilder bodyBuilder;
     private final MessageFiller[] inFillers;
     protected final String soapAction;
     protected final boolean isOneWay;
     protected final JavaMethodImpl javaMethod;
     protected final Map<QName, CheckedExceptionImpl> checkedExceptions;
     protected SOAPVersion soapVersion = SOAPVersion.SOAP_11;
     protected ResponseBuilder responseBuilder;
     protected MessageContextFactory packetFactory;
     public StubHandler(JavaMethodImpl method, MessageContextFactory mcf) {
         //keep all the CheckedException model for the detail qname
         this.checkedExceptions = new HashMap<QName, CheckedExceptionImpl>();
         for(CheckedExceptionImpl ce : method.getCheckedExceptions()){
             checkedExceptions.put(ce.getBond().getTypeInfo().tagName, ce);
         }
         //If a non-"" soapAction is specified, wsa:action the SOAPAction
         String soapActionFromBinding = method.getBinding().getSOAPAction();
         if(method.getInputAction() != null && soapActionFromBinding != null && !soapActionFromBinding.equals("") ) {
             this.soapAction = method.getInputAction();
         } else {
             this.soapAction = soapActionFromBinding;
         }
         this.javaMethod = method;
         packetFactory = mcf;
         soapVersion = javaMethod.getBinding().getSOAPVersion();
         {// prepare objects for creating messages
             List<ParameterImpl> rp = method.getRequestParameters();
             BodyBuilder bodyBuilder = null;
             List<MessageFiller> fillers = new ArrayList<MessageFiller>();
             for (ParameterImpl param : rp) {
                 ValueGetter getter = getValueGetterFactory().get(param);
                 switch(param.getInBinding().kind) {
                 case BODY:
                     if(param.isWrapperStyle()) {
                         if(param.getParent().getBinding().isRpcLit())
                             bodyBuilder = new BodyBuilder.RpcLit((WrapperParameter)param, soapVersion, getValueGetterFactory());
                         else
                             bodyBuilder = new BodyBuilder.DocLit((WrapperParameter)param, soapVersion, getValueGetterFactory());
                     } else {
                         bodyBuilder = new BodyBuilder.Bare(param, soapVersion, getter);
                     }
                     break;
                 case HEADER:
                     fillers.add(new MessageFiller.Header(
                         param.getIndex(),
                         param.getXMLBridge(),
                         getter ));
                     break;
                 case ATTACHMENT:
                     fillers.add(MessageFiller.AttachmentFiller.createAttachmentFiller(param, getter));
                     break;
                 case UNBOUND:
                     break;
                 default:
                     throw new AssertionError(); // impossible
                 }
             }
             if(bodyBuilder==null) {
                 // no parameter binds to body. we create an empty message
                 switch(soapVersion) {
                 case SOAP_11:
                     bodyBuilder = BodyBuilder.EMPTY_SOAP11;
                     break;
                 case SOAP_12:
                     bodyBuilder = BodyBuilder.EMPTY_SOAP12;
                     break;
                 default:
                     throw new AssertionError();
                 }
             }
             this.bodyBuilder = bodyBuilder;
             this.inFillers = fillers.toArray(new MessageFiller[fillers.size()]);
         }
         this.isOneWay = method.getMEP().isOneWay();
         responseBuilder = buildResponseBuilder(method, ValueSetterFactory.SYNC);
     }
     ResponseBuilder buildResponseBuilder(JavaMethodImpl method, ValueSetterFactory setterFactory) {
         // prepare objects for processing response
         List<ParameterImpl> rp = method.getResponseParameters();
         List<ResponseBuilder> builders = new ArrayList<ResponseBuilder>();
         for( ParameterImpl param : rp ) {
             ValueSetter setter;
             switch(param.getOutBinding().kind) {
             case BODY:
                 if(param.isWrapperStyle()) {
                     if(param.getParent().getBinding().isRpcLit())
                         builders.add(new ResponseBuilder.RpcLit((WrapperParameter)param, setterFactory));
                     else
                         builders.add(new ResponseBuilder.DocLit((WrapperParameter)param, setterFactory));
                 } else {
                     setter = setterFactory.get(param);
                     builders.add(new ResponseBuilder.Body(param.getXMLBridge(),setter));
                 }
                 break;
             case HEADER:
                 setter = setterFactory.get(param);
                 builders.add(new ResponseBuilder.Header(soapVersion, param, setter));
                 break;
             case ATTACHMENT:
                 setter = setterFactory.get(param);
                 builders.add(ResponseBuilder.AttachmentBuilder.createAttachmentBuilder(param, setter));
                 break;
             case UNBOUND:
                 setter = setterFactory.get(param);
                 builders.add(new ResponseBuilder.NullSetter(setter,
                     ResponseBuilder.getVMUninitializedValue(param.getTypeInfo().type)));
                 break;
             default:
                 throw new AssertionError();
             }
         }
         ResponseBuilder rb;
         switch(builders.size()) {
         case 0:
             rb = ResponseBuilder.NONE;
             break;
         case 1:
             rb = builders.get(0);
             break;
         default:
             rb = new ResponseBuilder.Composite(builders);
         }
         return rb;
     }
     /**
      * Creates a request {@link com.sun.xml.internal.ws.message.jaxb.JAXBMessage} from method arguments.
      * @param args proxy invocation arguments
      * @return Message for the arguments
      */
     public Packet createRequestPacket(JavaCallInfo args) {
         Message msg = bodyBuilder.createMessage(args.getParameters());
         for (MessageFiller filler : inFillers) filler.fillIn(args.getParameters(),msg);
         Packet req = (Packet)packetFactory.createContext(msg);
         req.setState(Packet.State.ClientRequest);
         req.soapAction = soapAction;
         req.expectReply = !isOneWay;
         req.getMessage().assertOneWay(isOneWay);
         req.setWSDLOperation(getOperationName());
         return req;
     }
     ValueGetterFactory getValueGetterFactory() {
         return ValueGetterFactory.SYNC;
     }
         public JavaCallInfo readResponse(Packet p, JavaCallInfo call) throws Throwable {
                 Message msg = p.getMessage();
         if(msg.isFault()) {
             SOAPFaultBuilder faultBuilder = SOAPFaultBuilder.create(msg);
             Throwable t = faultBuilder.createException(checkedExceptions);
             call.setException(t);
             throw t;
         } else {
                 initArgs(call.getParameters());
             Object ret = responseBuilder.readResponse(msg, call.getParameters());
             call.setReturnValue(ret);
             return call;
         }
         }
         public QName getOperationName() {
                 //TODO javaMethod.getOperation()
                 return javaMethod.getOperationQName();
         }
         public String getSoapAction() {
                 return soapAction;
         }
         public boolean isOneWay() {
                 return isOneWay;
         }
         protected void initArgs(Object[] args) throws Exception {
         }
         public Method getMethod() {
                 return javaMethod.getMethod();
         }
     public JavaMethod getOperationModel() {
         return javaMethod;
     }
 }

Mercurial > jdk8-mips64-public > jaxws / annotate

src/share/jaxws_classes/com/sun/xml/internal/ws/client/sei/StubHandler.java@9c07ef4934dd (annotated)

src/share/jaxws_classes/com/sun/xml/internal/ws/client/sei/StubHandler.java