Mercurial > hg > release > icedtea7-forest-2.1 > jaxws
view sources/jaxws_src/src/com/sun/xml/internal/ws/server/sei/PayloadQNameBasedDispatcher.java @ 282:78c175236707
Update to jdk7-jaxws-2009_09_28.zip
author | andrew |
---|---|
date | Thu, 22 Sep 2011 02:57:13 +0100 |
parents | c608b38af726 |
children |
line wrap: on
line source
/* * Copyright 2005-2006 Sun Microsystems, Inc. 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. Sun designates this * particular file as subject to the "Classpath" exception as provided * by Sun 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 Sun Microsystems, Inc., 4150 Network Circle, Santa Clara, * CA 95054 USA or visit www.sun.com if you need additional information or * have any questions. */ package com.sun.xml.internal.ws.server.sei; import com.sun.istack.internal.Nullable; 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.fault.SOAPFaultBuilder; import com.sun.xml.internal.ws.model.AbstractSEIModelImpl; import com.sun.xml.internal.ws.model.JavaMethodImpl; import com.sun.xml.internal.ws.resources.ServerMessages; import com.sun.xml.internal.ws.util.QNameMap; import javax.xml.namespace.QName; import java.util.ArrayList; import java.util.List; import java.util.logging.Logger; /** * An {@link com.sun.xml.internal.ws.server.sei.EndpointMethodDispatcher} that uses * SOAP payload first child's QName as the key for dispatching. * <p/> * A map of all payload QNames on the port and the corresponding {@link EndpointMethodHandler} * is initialized in the constructor. The payload QName is extracted from the * request {@link Packet} and used as the key to return the correct * handler. * * @author Arun Gupta * @author Jitendra Kotamraju */ final class PayloadQNameBasedDispatcher implements EndpointMethodDispatcher { private static final Logger LOGGER = Logger.getLogger(PayloadQNameBasedDispatcher.class.getName()); private static final String EMPTY_PAYLOAD_LOCAL = ""; private static final String EMPTY_PAYLOAD_NSURI = ""; private static final QName EMPTY_PAYLOAD = new QName(EMPTY_PAYLOAD_NSURI, EMPTY_PAYLOAD_LOCAL); private final QNameMap<EndpointMethodHandler> methodHandlers = new QNameMap<EndpointMethodHandler>(); private final QNameMap<List<String>> unique = new QNameMap<List<String>>(); private final WSBinding binding; public PayloadQNameBasedDispatcher(AbstractSEIModelImpl model, WSBinding binding, SEIInvokerTube invokerTube) { this.binding = binding; // Find if any payload QNames repeat for operations for(JavaMethodImpl m : model.getJavaMethods()) { QName name = m.getRequestPayloadName(); if (name == null) name = EMPTY_PAYLOAD; List<String> methods = unique.get(name); if (methods == null) { methods = new ArrayList<String>(); unique.put(name, methods); } methods.add(m.getMethod().getName()); } // Log warnings about non unique payload QNames for(QNameMap.Entry<List<String>> e : unique.entrySet()) { if (e.getValue().size() > 1) { LOGGER.warning(ServerMessages.NON_UNIQUE_DISPATCH_QNAME(e.getValue(), e.createQName())); } } for( JavaMethodImpl m : model.getJavaMethods()) { QName name = m.getRequestPayloadName(); if (name == null) name = EMPTY_PAYLOAD; // Set up method handlers only for unique QNames. So that dispatching // happens consistently for a method if (unique.get(name).size() == 1) { methodHandlers.put(name, new EndpointMethodHandler(invokerTube,m,binding)); } } } /** * * @return not null if it finds a unique handler for the request * null otherwise * @throws DispatchException if the payload itself is incorrect */ public @Nullable EndpointMethodHandler getEndpointMethodHandler(Packet request) throws DispatchException { Message message = request.getMessage(); String localPart = message.getPayloadLocalPart(); String nsUri; if (localPart == null) { localPart = EMPTY_PAYLOAD_LOCAL; nsUri = EMPTY_PAYLOAD_NSURI; } else { nsUri = message.getPayloadNamespaceURI(); if(nsUri == null) nsUri = EMPTY_PAYLOAD_NSURI; } EndpointMethodHandler mh = methodHandlers.get(nsUri, localPart); // Check if payload itself is correct. Usually it is, so let us check last if (mh == null && !unique.containsKey(nsUri,localPart)) { String dispatchKey = "{" + nsUri + "}" + localPart; String faultString = ServerMessages.DISPATCH_CANNOT_FIND_METHOD(dispatchKey); throw new DispatchException(SOAPFaultBuilder.createSOAPFaultMessage( binding.getSOAPVersion(), faultString, binding.getSOAPVersion().faultCodeClient)); } return mh; } }