Mercurial > hg > release > icedtea7-forest-2.0 > jaxws
view sources/jaxws_src/src/com/sun/xml/internal/ws/transport/http/server/PortableConnectionImpl.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.transport.http.server; import com.sun.istack.internal.NotNull; import com.sun.xml.internal.ws.api.message.Packet; import com.sun.xml.internal.ws.api.server.WSEndpoint; import com.sun.xml.internal.ws.api.server.WebServiceContextDelegate; import com.sun.xml.internal.ws.api.server.PortAddressResolver; import com.sun.xml.internal.ws.transport.http.HttpAdapter; import com.sun.xml.internal.ws.transport.http.WSHTTPConnection; import com.sun.xml.internal.ws.developer.JAXWSProperties; import com.sun.xml.internal.ws.resources.WsservletMessages; import javax.xml.ws.handler.MessageContext; import javax.xml.ws.WebServiceException; import javax.xml.ws.spi.http.HttpExchange; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.security.Principal; import java.util.ArrayList; import java.util.List; import java.util.Map; /** * {@link WSHTTPConnection} used with Java SE endpoints. It provides connection * implementation using {@link HttpExchange} object. * * @author Jitendra Kotamraju */ final class PortableConnectionImpl extends WSHTTPConnection implements WebServiceContextDelegate { private final HttpExchange httpExchange; private int status; private final HttpAdapter adapter; private boolean outputWritten; public PortableConnectionImpl(@NotNull HttpAdapter adapter, @NotNull HttpExchange httpExchange) { this.adapter = adapter; this.httpExchange = httpExchange; } @Override @Property(value = {MessageContext.HTTP_REQUEST_HEADERS, Packet.INBOUND_TRANSPORT_HEADERS}) public @NotNull Map<String,List<String>> getRequestHeaders() { return httpExchange.getRequestHeaders(); } @Override public String getRequestHeader(String headerName) { return httpExchange.getRequestHeader(headerName); } @Override public void setResponseHeaders(Map<String,List<String>> headers) { Map<String, List<String>> r = httpExchange.getResponseHeaders(); r.clear(); for(Map.Entry <String, List<String>> entry : headers.entrySet()) { String name = entry.getKey(); List<String> values = entry.getValue(); // ignore headers that interfere with our correct operations if (!name.equalsIgnoreCase("Content-Length") && !name.equalsIgnoreCase("Content-Type")) { r.put(name,new ArrayList<String>(values)); } } } @Override @Property({MessageContext.HTTP_RESPONSE_HEADERS,Packet.OUTBOUND_TRANSPORT_HEADERS}) public Map<String,List<String>> getResponseHeaders() { return httpExchange.getResponseHeaders(); } @Override public void setContentTypeResponseHeader(@NotNull String value) { httpExchange.addResponseHeader("Content-Type", value); } @Override public void setStatus(int status) { this.status = status; } @Override @Property(MessageContext.HTTP_RESPONSE_CODE) public int getStatus() { return status; } public @NotNull InputStream getInput() throws IOException { return httpExchange.getRequestBody(); } public @NotNull OutputStream getOutput() throws IOException { assert !outputWritten; outputWritten = true; httpExchange.setStatus(getStatus()); return httpExchange.getResponseBody(); } public @NotNull WebServiceContextDelegate getWebServiceContextDelegate() { return this; } public Principal getUserPrincipal(Packet request) { return httpExchange.getUserPrincipal(); } public boolean isUserInRole(Packet request, String role) { return httpExchange.isUserInRole(role); } public @NotNull String getEPRAddress(Packet request, WSEndpoint endpoint) { PortAddressResolver resolver = adapter.owner.createPortAddressResolver(getBaseAddress()); String address = resolver.getAddressFor(endpoint.getServiceName(), endpoint.getPortName().getLocalPart()); if(address==null) throw new WebServiceException(WsservletMessages.SERVLET_NO_ADDRESS_AVAILABLE(endpoint.getPortName())); return address; } @Property(MessageContext.SERVLET_CONTEXT) public Object getServletContext() { return httpExchange.getAttribute(MessageContext.SERVLET_CONTEXT); } @Property(MessageContext.SERVLET_RESPONSE) public Object getServletResponse() { return httpExchange.getAttribute(MessageContext.SERVLET_RESPONSE); } @Property(MessageContext.SERVLET_REQUEST) public Object getServletRequest() { return httpExchange.getAttribute(MessageContext.SERVLET_REQUEST); } public String getWSDLAddress(@NotNull Packet request, @NotNull WSEndpoint endpoint) { String eprAddress = getEPRAddress(request,endpoint); if(adapter.getEndpoint().getPort() != null) return eprAddress+"?wsdl"; else return null; } @Override public boolean isSecure() { return httpExchange.getScheme().equals("https"); } @Override @Property(MessageContext.HTTP_REQUEST_METHOD) public @NotNull String getRequestMethod() { return httpExchange.getRequestMethod(); } @Override @Property(MessageContext.QUERY_STRING) public String getQueryString() { return httpExchange.getQueryString(); } @Override @Property(MessageContext.PATH_INFO) public String getPathInfo() { return httpExchange.getPathInfo(); } @Property(JAXWSProperties.HTTP_EXCHANGE) public HttpExchange getExchange() { return httpExchange; } @Override @NotNull public String getBaseAddress() { StringBuilder sb = new StringBuilder(); sb.append(httpExchange.getScheme()); sb.append("://"); sb.append(httpExchange.getLocalAddress().getHostName()); sb.append(":"); sb.append(httpExchange.getLocalAddress().getPort()); sb.append(httpExchange.getContextPath()); return sb.toString(); } @Override public String getProtocol() { return httpExchange.getProtocol(); } @Override public void setContentLengthResponseHeader(int value) { httpExchange.addResponseHeader("Content-Length", ""+value); } protected PropertyMap getPropertyMap() { return model; } private static final PropertyMap model; static { model = parse(PortableConnectionImpl.class); } }