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

Tue, 09 Apr 2013 14:51:13 +0100

author
alanb
date
Tue, 09 Apr 2013 14:51:13 +0100
changeset 368
0989ad8c0860
parent 286
f50545b5e2f1
child 637
9c07ef4934dd
permissions
-rw-r--r--

8010393: Update JAX-WS RI to 2.2.9-b12941
Reviewed-by: alanb, erikj
Contributed-by: miroslav.kos@oracle.com, martin.grebac@oracle.com

ohair@286 1 /*
alanb@368 2 * Copyright (c) 1997, 2012, Oracle and/or its affiliates. All rights reserved.
ohair@286 3 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
ohair@286 4 *
ohair@286 5 * This code is free software; you can redistribute it and/or modify it
ohair@286 6 * under the terms of the GNU General Public License version 2 only, as
ohair@286 7 * published by the Free Software Foundation. Oracle designates this
ohair@286 8 * particular file as subject to the "Classpath" exception as provided
ohair@286 9 * by Oracle in the LICENSE file that accompanied this code.
ohair@286 10 *
ohair@286 11 * This code is distributed in the hope that it will be useful, but WITHOUT
ohair@286 12 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
ohair@286 13 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
ohair@286 14 * version 2 for more details (a copy is included in the LICENSE file that
ohair@286 15 * accompanied this code).
ohair@286 16 *
ohair@286 17 * You should have received a copy of the GNU General Public License version
ohair@286 18 * 2 along with this work; if not, write to the Free Software Foundation,
ohair@286 19 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
ohair@286 20 *
ohair@286 21 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
ohair@286 22 * or visit www.oracle.com if you need additional information or have any
ohair@286 23 * questions.
ohair@286 24 */
ohair@286 25
ohair@286 26 package com.sun.xml.internal.ws.api.pipe;
ohair@286 27
ohair@286 28 import com.sun.istack.internal.NotNull;
ohair@286 29 import com.sun.istack.internal.Nullable;
ohair@286 30 import com.sun.xml.internal.ws.api.BindingID;
ohair@286 31 import com.sun.xml.internal.ws.api.pipe.helper.PipeAdapter;
ohair@286 32 import com.sun.xml.internal.ws.api.server.Container;
alanb@368 33 import com.sun.xml.internal.ws.assembler.MetroTubelineAssembler;
ohair@286 34 import com.sun.xml.internal.ws.util.ServiceFinder;
alanb@368 35 import java.util.logging.Level;
ohair@286 36
ohair@286 37 import java.util.logging.Logger;
ohair@286 38
ohair@286 39 /**
ohair@286 40 * Creates {@link TubelineAssembler}.
ohair@286 41 * <p/>
ohair@286 42 * <p/>
ohair@286 43 * To create a tubeline,
ohair@286 44 * the JAX-WS runtime locates {@link TubelineAssemblerFactory}s through
ohair@286 45 * the <tt>META-INF/services/com.sun.xml.internal.ws.api.pipe.TubelineAssemblerFactory</tt> files.
ohair@286 46 * Factories found are checked to see if it supports the given binding ID one by one,
ohair@286 47 * and the first valid {@link TubelineAssembler} returned will be used to create
ohair@286 48 * a tubeline.
ohair@286 49 *
ohair@286 50 * @author Jitendra Kotamraju
ohair@286 51 */
ohair@286 52 public abstract class TubelineAssemblerFactory {
ohair@286 53 /**
ohair@286 54 * Creates a {@link TubelineAssembler} applicable for the given binding ID.
ohair@286 55 *
ohair@286 56 * @param bindingId The binding ID for which a tubeline will be created,
ohair@286 57 * such as {@link javax.xml.ws.soap.SOAPBinding#SOAP11HTTP_BINDING}.
ohair@286 58 * Must not be null.
ohair@286 59 * @return null if this factory doesn't recognize the given binding ID.
ohair@286 60 */
ohair@286 61 public abstract TubelineAssembler doCreate(BindingID bindingId);
ohair@286 62
ohair@286 63 /**
ohair@286 64 * @deprecated
ohair@286 65 * Use {@link #create(ClassLoader, BindingID, Container)}
ohair@286 66 */
ohair@286 67 public static TubelineAssembler create(ClassLoader classLoader, BindingID bindingId) {
ohair@286 68 return create(classLoader,bindingId,null);
ohair@286 69 }
ohair@286 70
ohair@286 71 /**
ohair@286 72 * Locates {@link TubelineAssemblerFactory}s and create
ohair@286 73 * a suitable {@link TubelineAssembler}.
ohair@286 74 *
ohair@286 75 * @param bindingId The binding ID string for which the new {@link TubelineAssembler}
ohair@286 76 * is created. Must not be null.
ohair@286 77 * @param container
ohair@286 78 * if specified, the container is given a chance to specify a {@link TubelineAssembler}
ohair@286 79 * instance. This parameter should be always given on the server, but can be null.
ohair@286 80 * @return Always non-null, since we fall back to our default {@link TubelineAssembler}.
ohair@286 81 */
ohair@286 82 public static TubelineAssembler create(ClassLoader classLoader, BindingID bindingId, @Nullable Container container) {
ohair@286 83
ohair@286 84 if(container!=null) {
ohair@286 85 // first allow the container to control pipeline for individual endpoint.
ohair@286 86 TubelineAssemblerFactory taf = container.getSPI(TubelineAssemblerFactory.class);
ohair@286 87 if(taf!=null) {
ohair@286 88 TubelineAssembler a = taf.doCreate(bindingId);
alanb@368 89 if (a != null) {
ohair@286 90 return a;
alanb@368 91 }
ohair@286 92 }
ohair@286 93 }
ohair@286 94
ohair@286 95 for (TubelineAssemblerFactory factory : ServiceFinder.find(TubelineAssemblerFactory.class, classLoader)) {
ohair@286 96 TubelineAssembler assembler = factory.doCreate(bindingId);
ohair@286 97 if (assembler != null) {
alanb@368 98 TubelineAssemblerFactory.logger.log(Level.FINE, "{0} successfully created {1}", new Object[]{factory.getClass(), assembler});
ohair@286 99 return assembler;
ohair@286 100 }
ohair@286 101 }
ohair@286 102
ohair@286 103 // See if there is a PipelineAssembler out there and use it for compatibility.
ohair@286 104 for (PipelineAssemblerFactory factory : ServiceFinder.find(PipelineAssemblerFactory.class,classLoader)) {
ohair@286 105 PipelineAssembler assembler = factory.doCreate(bindingId);
ohair@286 106 if(assembler!=null) {
alanb@368 107 logger.log(Level.FINE, "{0} successfully created {1}", new Object[]{factory.getClass(), assembler});
ohair@286 108 return new TubelineAssemblerAdapter(assembler);
ohair@286 109 }
ohair@286 110 }
ohair@286 111
ohair@286 112 // default binding IDs that are known
alanb@368 113 return new MetroTubelineAssembler(bindingId, MetroTubelineAssembler.JAXWS_TUBES_CONFIG_NAMES);
ohair@286 114 }
ohair@286 115
ohair@286 116 private static class TubelineAssemblerAdapter implements TubelineAssembler {
ohair@286 117 private PipelineAssembler assembler;
ohair@286 118
ohair@286 119 TubelineAssemblerAdapter(PipelineAssembler assembler) {
ohair@286 120 this.assembler = assembler;
ohair@286 121 }
ohair@286 122
alanb@368 123 @Override
ohair@286 124 public @NotNull Tube createClient(@NotNull ClientTubeAssemblerContext context) {
ohair@286 125 ClientPipeAssemblerContext ctxt = new ClientPipeAssemblerContext(
ohair@286 126 context.getAddress(), context.getWsdlModel(), context.getService(),
ohair@286 127 context.getBinding(), context.getContainer());
ohair@286 128 return PipeAdapter.adapt(assembler.createClient(ctxt));
ohair@286 129 }
ohair@286 130
alanb@368 131 @Override
ohair@286 132 public @NotNull Tube createServer(@NotNull ServerTubeAssemblerContext context) {
alanb@368 133 if (!(context instanceof ServerPipeAssemblerContext)) {
alanb@368 134 throw new IllegalArgumentException("{0} is not instance of ServerPipeAssemblerContext");
alanb@368 135 }
ohair@286 136 return PipeAdapter.adapt(assembler.createServer((ServerPipeAssemblerContext) context));
ohair@286 137 }
ohair@286 138 }
ohair@286 139
ohair@286 140 private static final Logger logger = Logger.getLogger(TubelineAssemblerFactory.class.getName());
ohair@286 141 }

mercurial