1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000 1.2 +++ b/src/share/jaxws_classes/com/sun/xml/internal/ws/server/sei/TieHandler.java Tue Mar 06 16:09:35 2012 -0800 1.3 @@ -0,0 +1,331 @@ 1.4 +/* 1.5 + * Copyright (c) 1997, 2011, Oracle and/or its affiliates. All rights reserved. 1.6 + * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. 1.7 + * 1.8 + * This code is free software; you can redistribute it and/or modify it 1.9 + * under the terms of the GNU General Public License version 2 only, as 1.10 + * published by the Free Software Foundation. Oracle designates this 1.11 + * particular file as subject to the "Classpath" exception as provided 1.12 + * by Oracle in the LICENSE file that accompanied this code. 1.13 + * 1.14 + * This code is distributed in the hope that it will be useful, but WITHOUT 1.15 + * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or 1.16 + * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License 1.17 + * version 2 for more details (a copy is included in the LICENSE file that 1.18 + * accompanied this code). 1.19 + * 1.20 + * You should have received a copy of the GNU General Public License version 1.21 + * 2 along with this work; if not, write to the Free Software Foundation, 1.22 + * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA. 1.23 + * 1.24 + * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA 1.25 + * or visit www.oracle.com if you need additional information or have any 1.26 + * questions. 1.27 + */ 1.28 + 1.29 +package com.sun.xml.internal.ws.server.sei; 1.30 + 1.31 +import com.sun.xml.internal.ws.api.SOAPVersion; 1.32 +import com.sun.xml.internal.ws.api.WSBinding; 1.33 +import com.sun.xml.internal.ws.api.databinding.EndpointCallBridge; 1.34 +import com.sun.xml.internal.ws.api.databinding.JavaCallInfo; 1.35 +import com.sun.xml.internal.ws.api.message.Message; 1.36 +import com.sun.xml.internal.ws.api.message.Packet; 1.37 +import com.sun.xml.internal.ws.api.model.JavaMethod; 1.38 +import com.sun.xml.internal.ws.fault.SOAPFaultBuilder; 1.39 +import com.sun.xml.internal.ws.message.jaxb.JAXBMessage; 1.40 +import com.sun.xml.internal.ws.model.JavaMethodImpl; 1.41 +import com.sun.xml.internal.ws.model.ParameterImpl; 1.42 +import com.sun.xml.internal.ws.model.WrapperParameter; 1.43 +import com.sun.xml.internal.ws.wsdl.DispatchException; 1.44 + 1.45 +import javax.jws.WebParam.Mode; 1.46 +import javax.xml.bind.JAXBException; 1.47 +import javax.xml.stream.XMLStreamException; 1.48 +import javax.xml.ws.Holder; 1.49 +import javax.xml.ws.ProtocolException; 1.50 +import javax.xml.ws.WebServiceException; 1.51 +import java.lang.reflect.InvocationTargetException; 1.52 +import java.lang.reflect.Method; 1.53 +import java.util.ArrayList; 1.54 +import java.util.List; 1.55 +import java.util.logging.Level; 1.56 +import java.util.logging.Logger; 1.57 + 1.58 +/** 1.59 + * 1.60 + * <p> 1.61 + * This class mainly performs the following two tasks: 1.62 + * <ol> 1.63 + * <li>Takes a {@link Message] that represents a request, 1.64 + * and extracts the arguments (and updates {@link Holder}s.) 1.65 + * <li>Accepts return value and {@link Holder} arguments for a Java method, 1.66 + * and creates {@link JAXBMessage} that represents a response message. 1.67 + * </ol> 1.68 + * 1.69 + * <h2>Creating {@link JAXBMessage}</h2> 1.70 + * <p> 1.71 + * At the construction time, we prepare {@link EndpointArgumentsBuilder} that knows how to create endpoint {@link Method} 1.72 + * invocation arguments. 1.73 + * we also prepare {@link EndpointResponseMessageBuilder} and {@link MessageFiller}s 1.74 + * that know how to move arguments into a {@link Message}. 1.75 + * Some arguments go to the payload, some go to headers, still others go to attachments. 1.76 + * 1.77 + * @author Jitendra Kotamraju 1.78 + * @author shih-chang.chen@oracle.com 1.79 + * Refactored from EndpointMethodHandler 1.80 + */ 1.81 +final public class TieHandler implements EndpointCallBridge { 1.82 + 1.83 + private final SOAPVersion soapVersion; 1.84 + private final Method method; 1.85 + private final int noOfArgs; 1.86 + private final JavaMethodImpl javaMethodModel; 1.87 + 1.88 + private final Boolean isOneWay; 1.89 + 1.90 + // Converts {@link Message} --> Object[] 1.91 + private final EndpointArgumentsBuilder argumentsBuilder; 1.92 + 1.93 + // these objects together create a response message from method parameters 1.94 + private final EndpointResponseMessageBuilder bodyBuilder; 1.95 + private final MessageFiller[] outFillers; 1.96 + 1.97 + public TieHandler(JavaMethodImpl method, WSBinding binding) { 1.98 + this.soapVersion = binding.getSOAPVersion(); 1.99 + this.method = method.getMethod(); 1.100 + this.javaMethodModel = method; 1.101 + argumentsBuilder = createArgumentsBuilder(); 1.102 + List<MessageFiller> fillers = new ArrayList<MessageFiller>(); 1.103 + bodyBuilder = createResponseMessageBuilder(fillers); 1.104 + this.outFillers = fillers.toArray(new MessageFiller[fillers.size()]); 1.105 + this.isOneWay = method.getMEP().isOneWay(); 1.106 + this.noOfArgs = this.method.getParameterTypes().length; 1.107 + } 1.108 + 1.109 + /** 1.110 + * It builds EndpointArgumentsBuilder which converts request {@link Message} to endpoint method's invocation 1.111 + * arguments Object[] 1.112 + * 1.113 + * @return EndpointArgumentsBuilder 1.114 + */ 1.115 + private EndpointArgumentsBuilder createArgumentsBuilder() { 1.116 + EndpointArgumentsBuilder argsBuilder; 1.117 + List<ParameterImpl> rp = javaMethodModel.getRequestParameters(); 1.118 + List<EndpointArgumentsBuilder> builders = new ArrayList<EndpointArgumentsBuilder>(); 1.119 + 1.120 + for( ParameterImpl param : rp ) { 1.121 + EndpointValueSetter setter = EndpointValueSetter.get(param); 1.122 + switch(param.getInBinding().kind) { 1.123 + case BODY: 1.124 + if(param.isWrapperStyle()) { 1.125 + if(param.getParent().getBinding().isRpcLit()) 1.126 + builders.add(new EndpointArgumentsBuilder.RpcLit((WrapperParameter)param)); 1.127 + else 1.128 + builders.add(new EndpointArgumentsBuilder.DocLit((WrapperParameter)param, Mode.OUT)); 1.129 + } else { 1.130 + builders.add(new EndpointArgumentsBuilder.Body(param.getXMLBridge(),setter)); 1.131 + } 1.132 + break; 1.133 + case HEADER: 1.134 + builders.add(new EndpointArgumentsBuilder.Header(soapVersion, param, setter)); 1.135 + break; 1.136 + case ATTACHMENT: 1.137 + builders.add(EndpointArgumentsBuilder.AttachmentBuilder.createAttachmentBuilder(param, setter)); 1.138 + break; 1.139 + case UNBOUND: 1.140 + builders.add(new EndpointArgumentsBuilder.NullSetter(setter, 1.141 + EndpointArgumentsBuilder.getVMUninitializedValue(param.getTypeInfo().type))); 1.142 + break; 1.143 + default: 1.144 + throw new AssertionError(); 1.145 + } 1.146 + } 1.147 + 1.148 + // creates {@link Holder} arguments for OUT parameters 1.149 + List<ParameterImpl> resp = javaMethodModel.getResponseParameters(); 1.150 + for( ParameterImpl param : resp ) { 1.151 + if (param.isWrapperStyle()) { 1.152 + WrapperParameter wp = (WrapperParameter)param; 1.153 + List<ParameterImpl> children = wp.getWrapperChildren(); 1.154 + for (ParameterImpl p : children) { 1.155 + if (p.isOUT() && p.getIndex() != -1) { 1.156 + EndpointValueSetter setter = EndpointValueSetter.get(p); 1.157 + builders.add(new EndpointArgumentsBuilder.NullSetter(setter, null)); 1.158 + } 1.159 + } 1.160 + } else if (param.isOUT() && param.getIndex() != -1) { 1.161 + EndpointValueSetter setter = EndpointValueSetter.get(param); 1.162 + builders.add(new EndpointArgumentsBuilder.NullSetter(setter, null)); 1.163 + } 1.164 + } 1.165 + 1.166 + switch(builders.size()) { 1.167 + case 0: 1.168 + argsBuilder = EndpointArgumentsBuilder.NONE; 1.169 + break; 1.170 + case 1: 1.171 + argsBuilder = builders.get(0); 1.172 + break; 1.173 + default: 1.174 + argsBuilder = new EndpointArgumentsBuilder.Composite(builders); 1.175 + } 1.176 + return argsBuilder; 1.177 + } 1.178 + 1.179 + /** 1.180 + * prepare objects for creating response {@link Message} 1.181 + */ 1.182 + private EndpointResponseMessageBuilder createResponseMessageBuilder(List<MessageFiller> fillers) { 1.183 + 1.184 + EndpointResponseMessageBuilder bodyBuilder = null; 1.185 + List<ParameterImpl> rp = javaMethodModel.getResponseParameters(); 1.186 + 1.187 + for (ParameterImpl param : rp) { 1.188 + ValueGetter getter = ValueGetter.get(param); 1.189 + 1.190 + switch(param.getOutBinding().kind) { 1.191 + case BODY: 1.192 + if(param.isWrapperStyle()) { 1.193 + if(param.getParent().getBinding().isRpcLit()) { 1.194 + bodyBuilder = new EndpointResponseMessageBuilder.RpcLit((WrapperParameter)param, 1.195 + soapVersion); 1.196 + } else { 1.197 + bodyBuilder = new EndpointResponseMessageBuilder.DocLit((WrapperParameter)param, 1.198 + soapVersion); 1.199 + } 1.200 + } else { 1.201 + bodyBuilder = new EndpointResponseMessageBuilder.Bare(param, soapVersion); 1.202 + } 1.203 + break; 1.204 + case HEADER: 1.205 + fillers.add(new MessageFiller.Header(param.getIndex(), param.getXMLBridge(), getter )); 1.206 + break; 1.207 + case ATTACHMENT: 1.208 + fillers.add(MessageFiller.AttachmentFiller.createAttachmentFiller(param, getter)); 1.209 + break; 1.210 + case UNBOUND: 1.211 + break; 1.212 + default: 1.213 + throw new AssertionError(); // impossible 1.214 + } 1.215 + } 1.216 + 1.217 + if (bodyBuilder == null) { 1.218 + // no parameter binds to body. we create an empty message 1.219 + switch(soapVersion) { 1.220 + case SOAP_11: 1.221 + bodyBuilder = EndpointResponseMessageBuilder.EMPTY_SOAP11; 1.222 + break; 1.223 + case SOAP_12: 1.224 + bodyBuilder = EndpointResponseMessageBuilder.EMPTY_SOAP12; 1.225 + break; 1.226 + default: 1.227 + throw new AssertionError(); 1.228 + } 1.229 + } 1.230 + return bodyBuilder; 1.231 + } 1.232 + 1.233 + public Object[] readRequest(Message reqMsg) { 1.234 + Object[] args = new Object[noOfArgs]; 1.235 + try { 1.236 + argumentsBuilder.readRequest(reqMsg,args); 1.237 + } catch (JAXBException e) { 1.238 + throw new WebServiceException(e); 1.239 + } catch (XMLStreamException e) { 1.240 + throw new WebServiceException(e); 1.241 + } 1.242 + return args; 1.243 + } 1.244 + 1.245 + public Message createResponse(JavaCallInfo call) { 1.246 + Message responseMessage; 1.247 + Object ret = call.getReturnValue(); 1.248 + if (call.getException() == null) { 1.249 + responseMessage = isOneWay ? null : createResponseMessage(call.getParameters(), call.getReturnValue()); 1.250 + } else { 1.251 + Throwable e = call.getException(); 1.252 + Throwable serviceException = getServiceException(e); 1.253 + if (e instanceof InvocationTargetException || serviceException != null) { 1.254 +// Throwable cause = e.getCause(); 1.255 + //if (!(cause instanceof RuntimeException) && cause instanceof Exception) { 1.256 + if (serviceException != null) { 1.257 + // Service specific exception 1.258 + LOGGER.log(Level.FINE, serviceException.getMessage(), serviceException); 1.259 + responseMessage = SOAPFaultBuilder.createSOAPFaultMessage(soapVersion, 1.260 + javaMethodModel.getCheckedException(serviceException.getClass()), serviceException); 1.261 + } else { 1.262 + Throwable cause = e.getCause(); 1.263 + if (cause instanceof ProtocolException) { 1.264 + // Application code may be throwing it intentionally 1.265 + LOGGER.log(Level.FINE, cause.getMessage(), cause); 1.266 + } else { 1.267 + // Probably some bug in application code 1.268 + LOGGER.log(Level.SEVERE, cause.getMessage(), cause); 1.269 + } 1.270 + responseMessage = SOAPFaultBuilder.createSOAPFaultMessage(soapVersion, null, cause); 1.271 + } 1.272 + } else if (e instanceof DispatchException) { 1.273 + responseMessage = ((DispatchException)e).fault; 1.274 + } else { 1.275 + LOGGER.log(Level.SEVERE, e.getMessage(), e); 1.276 + responseMessage = SOAPFaultBuilder.createSOAPFaultMessage(soapVersion, null, e); 1.277 + } 1.278 + } 1.279 +// return req.createServerResponse(responseMessage, req.endpoint.getPort(), javaMethodModel.getOwner(), req.endpoint.getBinding()); 1.280 + 1.281 + return responseMessage; 1.282 + } 1.283 + 1.284 + Throwable getServiceException(Throwable throwable) { 1.285 + if (javaMethodModel.getCheckedException(throwable.getClass()) != null) return throwable; 1.286 + if (throwable.getCause() != null) { 1.287 + Throwable cause = throwable.getCause(); 1.288 +// if (!(cause instanceof RuntimeException) && cause instanceof Exception) { 1.289 + if (javaMethodModel.getCheckedException(cause.getClass()) != null) return cause; 1.290 +// } 1.291 +// if (javaMethodModel.getCheckedException(cause.getClass()) != null) return cause; 1.292 + } 1.293 + return null; 1.294 + } 1.295 + 1.296 + /** 1.297 + * Creates a response {@link JAXBMessage} from method arguments, return value 1.298 + * 1.299 + * @return response message 1.300 + */ 1.301 + private Message createResponseMessage(Object[] args, Object returnValue) { 1.302 + Message msg = bodyBuilder.createMessage(args, returnValue); 1.303 + 1.304 + for (MessageFiller filler : outFillers) 1.305 + filler.fillIn(args, returnValue, msg); 1.306 + 1.307 + return msg; 1.308 + } 1.309 + 1.310 + public Method getMethod() { 1.311 + return method; 1.312 + } 1.313 + 1.314 + private static final Logger LOGGER = Logger.getLogger(TieHandler.class.getName()); 1.315 + 1.316 + public JavaCallInfo deserializeRequest(Packet req) { 1.317 + JavaCallInfo call = new JavaCallInfo(); 1.318 + call.setMethod(this.getMethod()); 1.319 + Object[] args = this.readRequest(req.getMessage()); 1.320 + call.setParameters(args); 1.321 + return call; 1.322 + } 1.323 + 1.324 + public Packet serializeResponse(JavaCallInfo call) { 1.325 + Message msg = this.createResponse(call); 1.326 + Packet response = new Packet(); 1.327 + response.setMessage(msg); 1.328 + return response; 1.329 + } 1.330 + 1.331 + public JavaMethod getOperationModel() { 1.332 + return javaMethodModel; 1.333 + } 1.334 +}