Mercurial > hg > release > icedtea7-forest-2.1 > jaxws
view sources/jaxws_src/src/com/sun/xml/internal/ws/server/sei/SEIInvokerTube.java @ 284:4f4a2cd249d8
6962317: jdk7 jaxws source bundle still needs rebranding
6955300: Missing files in the jaf source bundle
author | andrew |
---|---|
date | Fri, 23 Sep 2011 17:43:06 +0100 |
parents | 2a5e9984bdb8 |
children | dc83adaaef79 |
line wrap: on
line source
/* * Copyright (c) 2005, 2006, 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.server.sei; import com.sun.istack.internal.NotNull; import com.sun.xml.internal.ws.api.SOAPVersion; import com.sun.xml.internal.ws.api.WSBinding; import com.sun.xml.internal.ws.api.message.Message; import com.sun.xml.internal.ws.api.message.Packet; import com.sun.xml.internal.ws.api.pipe.NextAction; import com.sun.xml.internal.ws.api.server.Invoker; import com.sun.xml.internal.ws.client.sei.MethodHandler; import com.sun.xml.internal.ws.model.AbstractSEIModelImpl; import com.sun.xml.internal.ws.model.JavaMethodImpl; import com.sun.xml.internal.ws.server.InvokerTube; import com.sun.xml.internal.ws.server.WSEndpointImpl; import com.sun.xml.internal.ws.resources.ServerMessages; import com.sun.xml.internal.ws.fault.SOAPFaultBuilder; import com.sun.xml.internal.ws.wsdl.DispatchException; import com.sun.xml.internal.ws.util.QNameMap; import javax.xml.namespace.QName; import java.util.List; import java.util.Map; import java.text.MessageFormat; /** * This pipe is used to invoke SEI based endpoints. * * @author Jitendra Kotamraju */ public class SEIInvokerTube extends InvokerTube { /** * For each method on the port interface we have * a {@link MethodHandler} that processes it. */ private final WSBinding binding; private final AbstractSEIModelImpl model; //store WSDL Operation to EndpointMethodHandler map private final QNameMap<EndpointMethodHandler> wsdlOpMap; public SEIInvokerTube(AbstractSEIModelImpl model,Invoker invoker, WSBinding binding) { super(invoker); this.binding = binding; this.model = model; wsdlOpMap = new QNameMap<EndpointMethodHandler>(); for(JavaMethodImpl jm: model.getJavaMethods()) { wsdlOpMap.put(jm.getOperation().getName(),new EndpointMethodHandler(this,jm,binding)); } } /** * This binds the parameters for SEI endpoints and invokes the endpoint method. The * return value, and response Holder arguments are used to create a new {@link Message} * that traverses through the Pipeline to transport. */ public @NotNull NextAction processRequest(@NotNull Packet req) { QName wsdlOp; try { wsdlOp = ((WSEndpointImpl) getEndpoint()).getOperationDispatcher().getWSDLOperationQName(req); Packet res = wsdlOpMap.get(wsdlOp).invoke(req); assert res != null; return doReturnWith(res); } catch (DispatchException e) { return doReturnWith(req.createServerResponse(e.fault, model.getPort(), null, binding)); } } public @NotNull NextAction processResponse(@NotNull Packet response) { throw new IllegalStateException("InovkerPipe's processResponse shouldn't be called."); } public @NotNull NextAction processException(@NotNull Throwable t) { throw new IllegalStateException("InovkerPipe's processException shouldn't be called."); } }