jdk8-mips64-public/jaxws: comparison src/share/jaxws_classes/com/sun/xml/internal/ws/api/pipe/TubelineAssemblerFactory.java

--1:000000000000
+:373ffda63c9a
+/*
+* Copyright (c) 1997, 2012, 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.api.pipe;
+import com.sun.istack.internal.NotNull;
+import com.sun.istack.internal.Nullable;
+import com.sun.xml.internal.ws.api.BindingID;
+import com.sun.xml.internal.ws.api.pipe.helper.PipeAdapter;
+import com.sun.xml.internal.ws.api.server.Container;
+import com.sun.xml.internal.ws.assembler.MetroTubelineAssembler;
+import com.sun.xml.internal.ws.util.ServiceFinder;
+import java.util.logging.Level;
+import java.util.logging.Logger;
+/**
+* Creates {@link TubelineAssembler}.
+* <p/>
+* <p/>
+* To create a tubeline,
+* the JAX-WS runtime locates {@link TubelineAssemblerFactory}s through
+* the <tt>META-INF/services/com.sun.xml.internal.ws.api.pipe.TubelineAssemblerFactory</tt> files.
+* Factories found are checked to see if it supports the given binding ID one by one,
+* and the first valid {@link TubelineAssembler} returned will be used to create
+* a tubeline.
+*
+* @author Jitendra Kotamraju
+*/
+public abstract class TubelineAssemblerFactory {
+/**
+* Creates a {@link TubelineAssembler} applicable for the given binding ID.
+*
+* @param bindingId The binding ID for which a tubeline will be created,
+*                  such as {@link javax.xml.ws.soap.SOAPBinding#SOAP11HTTP_BINDING}.
+*                  Must not be null.
+* @return null if this factory doesn't recognize the given binding ID.
+*/
+public abstract TubelineAssembler doCreate(BindingID bindingId);
+/**
+* @deprecated
+*      Use {@link #create(ClassLoader, BindingID, Container)}
+*/
+public static TubelineAssembler create(ClassLoader classLoader, BindingID bindingId) {
+return create(classLoader,bindingId,null);
+}
+/**
+* Locates {@link TubelineAssemblerFactory}s and create
+* a suitable {@link TubelineAssembler}.
+*
+* @param bindingId The binding ID string for which the new {@link TubelineAssembler}
+*                  is created. Must not be null.
+* @param container
+*      if specified, the container is given a chance to specify a {@link TubelineAssembler}
+*      instance. This parameter should be always given on the server, but can be null.
+* @return Always non-null, since we fall back to our default {@link TubelineAssembler}.
+*/
+public static TubelineAssembler create(ClassLoader classLoader, BindingID bindingId, @Nullable Container container) {
+if(container!=null) {
+// first allow the container to control pipeline for individual endpoint.
+TubelineAssemblerFactory taf = container.getSPI(TubelineAssemblerFactory.class);
+if(taf!=null) {
+TubelineAssembler a = taf.doCreate(bindingId);
+if (a != null) {
+return a;
+}
+}
+}
+for (TubelineAssemblerFactory factory : ServiceFinder.find(TubelineAssemblerFactory.class, classLoader)) {
+TubelineAssembler assembler = factory.doCreate(bindingId);
+if (assembler != null) {
+TubelineAssemblerFactory.logger.log(Level.FINE, "{0} successfully created {1}", new Object[]{factory.getClass(), assembler});
+return assembler;
+}
+}
+// See if there is a PipelineAssembler out there and use it for compatibility.
+for (PipelineAssemblerFactory factory : ServiceFinder.find(PipelineAssemblerFactory.class,classLoader)) {
+PipelineAssembler assembler = factory.doCreate(bindingId);
+if(assembler!=null) {
+logger.log(Level.FINE, "{0} successfully created {1}", new Object[]{factory.getClass(), assembler});
+return new TubelineAssemblerAdapter(assembler);
+}
+}
+// default binding IDs that are known
+return new MetroTubelineAssembler(bindingId, MetroTubelineAssembler.JAXWS_TUBES_CONFIG_NAMES);
+}
+private static class TubelineAssemblerAdapter implements TubelineAssembler {
+private PipelineAssembler assembler;
+TubelineAssemblerAdapter(PipelineAssembler assembler) {
+this.assembler = assembler;
+}
+@Override
+public @NotNull Tube createClient(@NotNull ClientTubeAssemblerContext context) {
+ClientPipeAssemblerContext ctxt = new ClientPipeAssemblerContext(
+context.getAddress(), context.getWsdlModel(), context.getService(),
+context.getBinding(), context.getContainer());
+return PipeAdapter.adapt(assembler.createClient(ctxt));
+}
+@Override
+public @NotNull Tube createServer(@NotNull ServerTubeAssemblerContext context) {
+if (!(context instanceof ServerPipeAssemblerContext)) {
+throw new IllegalArgumentException("{0} is not instance of ServerPipeAssemblerContext");
+}
+return PipeAdapter.adapt(assembler.createServer((ServerPipeAssemblerContext) context));
+}
+}
+private static final Logger logger = Logger.getLogger(TubelineAssemblerFactory.class.getName());
+}

Mercurial > jdk8-mips64-public > jaxws / file comparison

comparison: src/share/jaxws_classes/com/sun/xml/internal/ws/api/pipe/TubelineAssemblerFactory.java

src/share/jaxws_classes/com/sun/xml/internal/ws/api/pipe/TubelineAssemblerFactory.java