Mercurial > hg > release > icedtea7-forest-2.1 > jaxws
view sources/jaxws_src/src/com/sun/xml/internal/ws/transport/DeferredTransportPipe.java @ 286:5d45300e33bb
7034918: Integrate JAX-WS 2.2.4-b01 in to JDK 7
author | andrew |
---|---|
date | Wed, 28 Sep 2011 01:59:37 +0100 |
parents | dc83adaaef79 |
children | 1a5e2ee2e853 |
line wrap: on
line source
/* * Copyright (c) 1997, 2010, 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; import com.sun.xml.internal.ws.api.EndpointAddress; import com.sun.xml.internal.ws.api.message.Packet; import com.sun.xml.internal.ws.api.pipe.*; import com.sun.xml.internal.ws.api.pipe.helper.AbstractTubeImpl; import com.sun.istack.internal.NotNull; import javax.xml.ws.BindingProvider; /** * Proxy transport {@link Tube} and {@link Pipe} that lazily determines the * actual transport pipe by looking at {@link Packet#endpointAddress}. * * <p> * This pseudo transport is used when there's no statically known endpoint address, * and thus it's expected that the application will configure {@link BindingProvider} * at runtime before making invocation. * * <p> * Since a typical application makes multiple invocations with the same endpoint * address, this class implements a simple cache strategy to avoid re-creating * transport pipes excessively. * * @author Kohsuke Kawaguchi */ public final class DeferredTransportPipe extends AbstractTubeImpl { private Tube transport; private EndpointAddress address; // parameter to TransportPipeFactory private final ClassLoader classLoader; private final ClientTubeAssemblerContext context; public DeferredTransportPipe(ClassLoader classLoader, ClientPipeAssemblerContext context) { this(classLoader, new ClientTubeAssemblerContext(context.getAddress(), context.getWsdlModel(), context.getBindingProvider(), context.getBinding(), context.getContainer(), context.getCodec(), context.getSEIModel())); } public DeferredTransportPipe(ClassLoader classLoader, ClientTubeAssemblerContext context) { this.classLoader = classLoader; this.context = context; //See if we can create the transport pipe from the available information. try { this.transport = TransportTubeFactory.create(classLoader, context); this.address = context.getAddress(); } catch(Exception e) { //No problem, transport will be initialized while processing the requests } } public DeferredTransportPipe(DeferredTransportPipe that, TubeCloner cloner) { super(that,cloner); this.classLoader = that.classLoader; this.context = that.context; if(that.transport!=null) { this.transport = ((PipeCloner)cloner).copy(that.transport); this.address = that.address; } } public NextAction processException(@NotNull Throwable t) { return transport.processException(t); } public NextAction processRequest(@NotNull Packet request) { if(request.endpointAddress==address) // cache hit return transport.processRequest(request); // cache miss if(transport!=null) { // delete the current entry transport.preDestroy(); transport = null; address = null; } // otherwise find out what transport will process this. ClientTubeAssemblerContext newContext = new ClientTubeAssemblerContext( request.endpointAddress, context.getWsdlModel(), context.getBindingProvider(), context.getBinding(), context.getContainer(), context.getCodec().copy(), context.getSEIModel() ); address = request.endpointAddress; transport = TransportTubeFactory.create(classLoader, newContext); // successful return from the above method indicates a successful pipe creation assert transport!=null; return transport.processRequest(request); } public NextAction processResponse(@NotNull Packet response) { return transport.processResponse(response); } public void preDestroy() { if(transport!=null) { transport.preDestroy(); transport = null; address = null; } } public DeferredTransportPipe copy(TubeCloner cloner) { return new DeferredTransportPipe(this,cloner); /* DeferredTransportPipe copy = new DeferredTransportPipe(classLoader,context); cloner.add(this,copy); // TODO Is the following thread-safe ?? // copied pipeline is still likely to work with the same endpoint address, // so also copy the cached transport pipe, if any if(transport!=null) { copy.transport = cloner.copy(this.transport); copy.address = this.address; } return copy; */ } }