ohair@286: /*
alanb@368:  * Copyright (c) 1997, 2013, Oracle and/or its affiliates. All rights reserved.
ohair@286:  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
ohair@286:  *
ohair@286:  * This code is free software; you can redistribute it and/or modify it
ohair@286:  * under the terms of the GNU General Public License version 2 only, as
ohair@286:  * published by the Free Software Foundation.  Oracle designates this
ohair@286:  * particular file as subject to the "Classpath" exception as provided
ohair@286:  * by Oracle in the LICENSE file that accompanied this code.
ohair@286:  *
ohair@286:  * This code is distributed in the hope that it will be useful, but WITHOUT
ohair@286:  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
ohair@286:  * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
ohair@286:  * version 2 for more details (a copy is included in the LICENSE file that
ohair@286:  * accompanied this code).
ohair@286:  *
ohair@286:  * You should have received a copy of the GNU General Public License version
ohair@286:  * 2 along with this work; if not, write to the Free Software Foundation,
ohair@286:  * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
ohair@286:  *
ohair@286:  * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
ohair@286:  * or visit www.oracle.com if you need additional information or have any
ohair@286:  * questions.
ohair@286:  */
ohair@286: 
ohair@286: package com.sun.xml.internal.ws.client;
ohair@286: 
ohair@286: import com.sun.istack.internal.NotNull;
ohair@286: import com.sun.istack.internal.Nullable;
ohair@286: import com.sun.xml.internal.ws.Closeable;
ohair@286: import com.sun.xml.internal.ws.api.BindingID;
ohair@286: import com.sun.xml.internal.ws.api.ComponentFeature;
alanb@368: import com.sun.xml.internal.ws.api.ComponentsFeature;
ohair@286: import com.sun.xml.internal.ws.api.ComponentFeature.Target;
ohair@286: import com.sun.xml.internal.ws.api.EndpointAddress;
ohair@286: import com.sun.xml.internal.ws.api.WSService;
ohair@286: import com.sun.xml.internal.ws.api.addressing.WSEndpointReference;
ohair@286: import com.sun.xml.internal.ws.api.client.ServiceInterceptor;
ohair@286: import com.sun.xml.internal.ws.api.client.ServiceInterceptorFactory;
alanb@368: import com.sun.xml.internal.ws.api.databinding.DatabindingConfig;
ohair@286: import com.sun.xml.internal.ws.api.databinding.DatabindingFactory;
alanb@368: import com.sun.xml.internal.ws.api.databinding.MetadataReader;
ohair@286: import com.sun.xml.internal.ws.api.model.SEIModel;
mkos@408: import com.sun.xml.internal.ws.api.model.wsdl.WSDLModel;
ohair@286: import com.sun.xml.internal.ws.api.model.wsdl.WSDLPort;
mkos@408: import com.sun.xml.internal.ws.api.model.wsdl.WSDLService;
alanb@368: import com.sun.xml.internal.ws.api.pipe.Stubs;
ohair@286: import com.sun.xml.internal.ws.api.server.Container;
ohair@286: import com.sun.xml.internal.ws.api.server.ContainerResolver;
ohair@286: import com.sun.xml.internal.ws.api.wsdl.parser.WSDLParserExtension;
ohair@286: import com.sun.xml.internal.ws.binding.BindingImpl;
ohair@286: import com.sun.xml.internal.ws.binding.WebServiceFeatureList;
ohair@286: import com.sun.xml.internal.ws.client.HandlerConfigurator.AnnotationConfigurator;
ohair@286: import com.sun.xml.internal.ws.client.HandlerConfigurator.HandlerResolverImpl;
ohair@286: import com.sun.xml.internal.ws.client.sei.SEIStub;
ohair@286: import com.sun.xml.internal.ws.developer.MemberSubmissionAddressingFeature;
alanb@368: import com.sun.xml.internal.ws.developer.UsesJAXBContextFeature;
ohair@286: import com.sun.xml.internal.ws.developer.WSBindingProvider;
ohair@286: import com.sun.xml.internal.ws.model.RuntimeModeler;
ohair@286: import com.sun.xml.internal.ws.model.SOAPSEIModel;
ohair@286: import com.sun.xml.internal.ws.resources.ClientMessages;
ohair@286: import com.sun.xml.internal.ws.resources.DispatchMessages;
ohair@286: import com.sun.xml.internal.ws.resources.ProviderApiMessages;
ohair@286: import com.sun.xml.internal.ws.util.JAXWSUtils;
ohair@286: import com.sun.xml.internal.ws.util.ServiceConfigurationError;
ohair@286: import com.sun.xml.internal.ws.util.ServiceFinder;
ohair@286: import com.sun.xml.internal.ws.wsdl.parser.RuntimeWSDLParser;
mkos@408: 
ohair@286: import org.xml.sax.EntityResolver;
ohair@286: import org.xml.sax.SAXException;
ohair@286: 
ohair@286: import javax.jws.HandlerChain;
ohair@286: import javax.jws.WebService;
ohair@286: import javax.xml.bind.JAXBContext;
ohair@286: import javax.xml.namespace.QName;
ohair@286: import javax.xml.stream.XMLStreamException;
ohair@286: import javax.xml.transform.Source;
ohair@286: import javax.xml.transform.stream.StreamSource;
alanb@368: import javax.xml.ws.BindingProvider;
alanb@368: import javax.xml.ws.Dispatch;
alanb@368: import javax.xml.ws.EndpointReference;
alanb@368: import javax.xml.ws.Service;
alanb@368: import javax.xml.ws.WebServiceClient;
alanb@368: import javax.xml.ws.WebServiceException;
alanb@368: import javax.xml.ws.WebServiceFeature;
ohair@286: import javax.xml.ws.handler.HandlerResolver;
ohair@286: import javax.xml.ws.soap.AddressingFeature;
mkos@408: 
ohair@286: import java.io.IOException;
ohair@286: import java.lang.reflect.InvocationHandler;
ohair@286: import java.lang.reflect.Proxy;
ohair@286: import java.net.MalformedURLException;
ohair@286: import java.net.URL;
mkos@384: import java.security.*;
alanb@368: import java.util.Collection;
alanb@368: import java.util.HashMap;
alanb@368: import java.util.HashSet;
alanb@368: import java.util.Iterator;
alanb@368: import java.util.Map;
alanb@368: import java.util.Set;
ohair@286: import java.util.concurrent.Executor;
ohair@286: import java.util.concurrent.ThreadFactory;
ohair@286: 
alanb@368: import static com.sun.xml.internal.ws.util.xml.XmlUtil.createDefaultCatalogResolver;
alanb@368: 
ohair@286: /**
ohair@286:  * <code>Service</code> objects provide the client view of a Web service.
ohair@286:  *
ohair@286:  * <p><code>Service</code> acts as a factory of the following:
ohair@286:  * <ul>
ohair@286:  * <li>Proxies for a target service endpoint.
ohair@286:  * <li>Instances of <code>javax.xml.ws.Dispatch</code> for
ohair@286:  * dynamic message-oriented invocation of a remote
ohair@286:  * operation.
ohair@286:  * </li>
ohair@286:  *
ohair@286:  * <p>The ports available on a service can be enumerated using the
ohair@286:  * <code>getPorts</code> method. Alternatively, you can pass a
ohair@286:  * service endpoint interface to the unary <code>getPort</code> method
ohair@286:  * and let the runtime select a compatible port.
ohair@286:  *
ohair@286:  * <p>Handler chains for all the objects created by a <code>Service</code>
ohair@286:  * can be set by means of the provided <code>HandlerRegistry</code>.
ohair@286:  *
ohair@286:  * <p>An <code>Executor</code> may be set on the service in order
ohair@286:  * to gain better control over the threads used to dispatch asynchronous
ohair@286:  * callbacks. For instance, thread pooling with certain parameters
ohair@286:  * can be enabled by creating a <code>ThreadPoolExecutor</code> and
ohair@286:  * registering it with the service.
ohair@286:  *
ohair@286:  * @author WS Development Team
ohair@286:  * @see Executor
ohair@286:  * @since JAX-WS 2.0
ohair@286:  */
ohair@286: public class WSServiceDelegate extends WSService {
ohair@286:     /**
ohair@286:      * All ports.
ohair@286:      * <p>
ohair@286:      * This includes ports statically known to WSDL, as well as
ohair@286:      * ones that are dynamically added
ohair@286:      * through {@link #addPort(QName, String, String)}.
ohair@286:      * <p>
ohair@286:      * For statically known ports we'll have {@link SEIPortInfo}.
ohair@286:      * For dynamically added ones we'll have {@link PortInfo}.
ohair@286:      */
ohair@286:     private final Map<QName, PortInfo> ports = new HashMap<QName, PortInfo>();
ohair@286:     // For monitoring
ohair@286:     protected Map<QName, PortInfo> getQNameToPortInfoMap() { return ports; }
ohair@286: 
ohair@286:     /**
ohair@286:      * Whenever we create {@link BindingProvider}, we use this to configure handlers.
ohair@286:      */
ohair@286:     private @NotNull HandlerConfigurator handlerConfigurator = new HandlerResolverImpl(null);
ohair@286: 
ohair@286:     private final Class<? extends Service> serviceClass;
ohair@286: 
ohair@286:     private final WebServiceFeatureList features;
ohair@286: 
ohair@286:     /**
ohair@286:      * Name of the service for which this {@link WSServiceDelegate} is created for.
ohair@286:      */
ohair@286:     private final @NotNull QName serviceName;
ohair@286: 
ohair@286:     /**
ohair@286:      * Information about SEI, keyed by their interface type.
ohair@286:      */
ohair@286:    // private final Map<Class,SEIPortInfo> seiContext = new HashMap<Class,SEIPortInfo>();
ohair@286:    private final Map<QName,SEIPortInfo> seiContext = new HashMap<QName,SEIPortInfo>();
ohair@286: 
ohair@286:     // This executor is used for all the async invocations for all proxies
ohair@286:     // created from this service. But once the proxy is created, then changing
ohair@286:     // this executor doesn't affect the already created proxies.
ohair@286:     private volatile Executor executor;
ohair@286: 
ohair@286:     /**
ohair@286:      * The WSDL service that this {@link Service} object represents.
ohair@286:      * <p>
ohair@286:      * This field is null iff no WSDL is given to {@link Service}.
ohair@286:      * This fiels can be be null if the service is created without wsdl but later
ohair@286:      * the epr supplies a wsdl that can be parsed.
ohair@286:      */
mkos@408:     private  @Nullable WSDLService wsdlService;
ohair@286: 
ohair@286:     private final Container container;
ohair@286:     /**
ohair@286:      * Multiple {@link ServiceInterceptor}s are aggregated into one.
ohair@286:      */
ohair@286:     /*package*/ final @NotNull ServiceInterceptor serviceInterceptor;
mkos@384:     private URL wsdlURL;
ohair@286: 
ohair@286:     public WSServiceDelegate(URL wsdlDocumentLocation, QName serviceName, Class<? extends Service> serviceClass, WebServiceFeature... features) {
alanb@368:         this(wsdlDocumentLocation, serviceName, serviceClass, new WebServiceFeatureList(features));
alanb@368:     }
alanb@368: 
alanb@368:     protected WSServiceDelegate(URL wsdlDocumentLocation, QName serviceName, Class<? extends Service> serviceClass, WebServiceFeatureList features) {
ohair@286:         this(
ohair@286:             wsdlDocumentLocation==null ? null : new StreamSource(wsdlDocumentLocation.toExternalForm()),
ohair@286:             serviceName,serviceClass, features);
mkos@384:         wsdlURL = wsdlDocumentLocation;
ohair@286:     }
ohair@286: 
ohair@286:     /**
ohair@286:      * @param serviceClass
ohair@286:      *      Either {@link Service}.class or other generated service-derived classes.
ohair@286:      */
ohair@286:     public WSServiceDelegate(@Nullable Source wsdl, @NotNull QName serviceName, @NotNull final Class<? extends Service> serviceClass, WebServiceFeature... features) {
alanb@368:         this(wsdl, serviceName, serviceClass, new WebServiceFeatureList(features));
alanb@368:     }
alanb@368: 
alanb@368:     /**
alanb@368:      * @param serviceClass
alanb@368:      *      Either {@link Service}.class or other generated service-derived classes.
alanb@368:      */
alanb@368:     protected WSServiceDelegate(@Nullable Source wsdl, @NotNull QName serviceName, @NotNull final Class<? extends Service> serviceClass, WebServiceFeatureList features) {
ohair@286:         this(wsdl, null, serviceName, serviceClass, features);
ohair@286:     }
ohair@286: 
ohair@286:     /**
ohair@286:      * @param serviceClass
ohair@286:      *      Either {@link Service}.class or other generated service-derived classes.
ohair@286:      */
mkos@408:     public WSServiceDelegate(@Nullable Source wsdl, @Nullable WSDLService service, @NotNull QName serviceName, @NotNull final Class<? extends Service> serviceClass, WebServiceFeature... features) {
alanb@368:         this(wsdl, service, serviceName, serviceClass, new WebServiceFeatureList(features));
alanb@368:     }
alanb@368: 
alanb@368:     /**
alanb@368:      * @param serviceClass
alanb@368:      *      Either {@link Service}.class or other generated service-derived classes.
alanb@368:      */
mkos@408:     public WSServiceDelegate(@Nullable Source wsdl, @Nullable WSDLService service, @NotNull QName serviceName, @NotNull final Class<? extends Service> serviceClass, WebServiceFeatureList features) {
ohair@286:         //we cant create a Service without serviceName
alanb@368:         if (serviceName == null) {
alanb@368:             throw new WebServiceException(ClientMessages.INVALID_SERVICE_NAME_NULL(null));
alanb@368:         }
ohair@286: 
alanb@368:         this.features = features;
ohair@286: 
ohair@286:         InitParams initParams = INIT_PARAMS.get();
ohair@286:         INIT_PARAMS.set(null);  // mark it as consumed
alanb@368:         if(initParams==null) {
alanb@368:             initParams = EMPTY_PARAMS;
alanb@368:         }
ohair@286: 
ohair@286:         this.serviceName = serviceName;
ohair@286:         this.serviceClass = serviceClass;
ohair@286:         Container tContainer = initParams.getContainer()!=null ? initParams.getContainer() : ContainerResolver.getInstance().getContainer();
ohair@286:         if (tContainer == Container.NONE) {
ohair@286:             tContainer = new ClientContainer();
ohair@286:         }
ohair@286:         this.container = tContainer;
ohair@286: 
ohair@286:         ComponentFeature cf = this.features.get(ComponentFeature.class);
ohair@286:         if (cf != null) {
ohair@286:             switch(cf.getTarget()) {
ohair@286:                 case SERVICE:
ohair@286:                     getComponents().add(cf.getComponent());
ohair@286:                     break;
ohair@286:                 case CONTAINER:
ohair@286:                     this.container.getComponents().add(cf.getComponent());
alanb@368:                     break;
ohair@286:                 default:
ohair@286:                     throw new IllegalArgumentException();
ohair@286:             }
ohair@286:         }
alanb@368:         ComponentsFeature csf = this.features.get(ComponentsFeature.class);
alanb@368:         if (csf != null) {
alanb@368:             for (ComponentFeature cfi : csf.getComponentFeatures()) {
alanb@368:                 switch(cfi.getTarget()) {
alanb@368:                     case SERVICE:
alanb@368:                         getComponents().add(cfi.getComponent());
alanb@368:                         break;
alanb@368:                     case CONTAINER:
alanb@368:                         this.container.getComponents().add(cfi.getComponent());
alanb@368:                         break;
alanb@368:                     default:
alanb@368:                         throw new IllegalArgumentException();
alanb@368:                 }
alanb@368:             }
alanb@368:         }
ohair@286: 
ohair@286:         // load interceptor
ohair@286:         ServiceInterceptor interceptor = ServiceInterceptorFactory.load(this, Thread.currentThread().getContextClassLoader());
ohair@286:         ServiceInterceptor si = container.getSPI(ServiceInterceptor.class);
ohair@286:         if (si != null) {
ohair@286:             interceptor = ServiceInterceptor.aggregate(interceptor, si);
ohair@286:         }
ohair@286:         this.serviceInterceptor = interceptor;
ohair@286: 
ohair@286:         if (service == null) {
ohair@286:                 //if wsdl is null, try and get it from the WebServiceClient.wsdlLocation
ohair@286:                 if(wsdl == null){
ohair@286:                     if(serviceClass != Service.class){
ohair@286:                         WebServiceClient wsClient = AccessController.doPrivileged(new PrivilegedAction<WebServiceClient>() {
ohair@286:                                 public WebServiceClient run() {
ohair@286:                                     return serviceClass.getAnnotation(WebServiceClient.class);
ohair@286:                                 }
ohair@286:                             });
ohair@286:                         String wsdlLocation = wsClient.wsdlLocation();
ohair@286:                         wsdlLocation = JAXWSUtils.absolutize(JAXWSUtils.getFileOrURLName(wsdlLocation));
ohair@286:                         wsdl = new StreamSource(wsdlLocation);
ohair@286:                     }
ohair@286:                 }
ohair@286:                 if (wsdl != null) {
ohair@286:                     try {
ohair@286:                         URL url = wsdl.getSystemId()==null ? null : JAXWSUtils.getEncodedURL(wsdl.getSystemId());
mkos@408:                         WSDLModel model = parseWSDL(url, wsdl, serviceClass);
ohair@286:                         service = model.getService(this.serviceName);
ohair@286:                         if (service == null)
ohair@286:                             throw new WebServiceException(
ohair@286:                                 ClientMessages.INVALID_SERVICE_NAME(this.serviceName,
ohair@286:                                     buildNameList(model.getServices().keySet())));
ohair@286:                         // fill in statically known ports
ohair@286:                         for (WSDLPort port : service.getPorts())
ohair@286:                             ports.put(port.getName(), new PortInfo(this, port));
ohair@286:                     } catch (MalformedURLException e) {
ohair@286:                         throw new WebServiceException(ClientMessages.INVALID_WSDL_URL(wsdl.getSystemId()));
ohair@286:                     }
ohair@286:                 }
mkos@408:         } else {
mkos@408:             // fill in statically known ports
mkos@408:             for (WSDLPort port : service.getPorts())
mkos@408:                 ports.put(port.getName(), new PortInfo(this, port));
ohair@286:         }
ohair@286:         this.wsdlService = service;
ohair@286: 
ohair@286:         if (serviceClass != Service.class) {
ohair@286:             //if @HandlerChain present, set HandlerResolver on service context
ohair@286:             HandlerChain handlerChain =
ohair@286:                     AccessController.doPrivileged(new PrivilegedAction<HandlerChain>() {
ohair@286:                         public HandlerChain run() {
ohair@286:                             return serviceClass.getAnnotation(HandlerChain.class);
ohair@286:                         }
ohair@286:                     });
ohair@286:             if (handlerChain != null)
ohair@286:                 handlerConfigurator = new AnnotationConfigurator(this);
ohair@286:         }
ohair@286: 
ohair@286:     }
ohair@286: 
ohair@286:     /**
ohair@286:      * Parses the WSDL and builds {@link com.sun.xml.internal.ws.api.model.wsdl.WSDLModel}.
ohair@286:      * @param wsdlDocumentLocation
ohair@286:      *      Either this or <tt>wsdl</tt> parameter must be given.
ohair@286:      *      Null location means the system won't be able to resolve relative references in the WSDL,
ohair@286:      */
mkos@408:     private WSDLModel parseWSDL(URL wsdlDocumentLocation, Source wsdlSource, Class serviceClass) {
ohair@286:         try {
ohair@286:             return RuntimeWSDLParser.parse(wsdlDocumentLocation, wsdlSource, createCatalogResolver(),
ohair@286:                 true, getContainer(), serviceClass, ServiceFinder.find(WSDLParserExtension.class).toArray());
ohair@286:         } catch (IOException e) {
ohair@286:             throw new WebServiceException(e);
ohair@286:         } catch (XMLStreamException e) {
ohair@286:             throw new WebServiceException(e);
ohair@286:         } catch (SAXException e) {
ohair@286:             throw new WebServiceException(e);
ohair@286:         } catch (ServiceConfigurationError e) {
ohair@286:             throw new WebServiceException(e);
ohair@286:         }
ohair@286:     }
ohair@286: 
ohair@286:     protected EntityResolver createCatalogResolver() {
ohair@286:         return createDefaultCatalogResolver();
ohair@286:     }
ohair@286: 
ohair@286:     public Executor getExecutor() {
ohair@286:         return executor;
ohair@286:     }
ohair@286: 
ohair@286:     public void setExecutor(Executor executor) {
ohair@286:         this.executor = executor;
ohair@286:     }
ohair@286: 
ohair@286:     public HandlerResolver getHandlerResolver() {
ohair@286:         return handlerConfigurator.getResolver();
ohair@286:     }
ohair@286: 
ohair@286:     /*package*/ final HandlerConfigurator getHandlerConfigurator() {
ohair@286:         return handlerConfigurator;
ohair@286:     }
ohair@286: 
ohair@286:     public void setHandlerResolver(HandlerResolver resolver) {
ohair@286:         handlerConfigurator = new HandlerResolverImpl(resolver);
ohair@286:     }
ohair@286: 
ohair@286:     public <T> T getPort(QName portName, Class<T> portInterface) throws WebServiceException {
ohair@286:         return getPort(portName, portInterface, EMPTY_FEATURES);
ohair@286:     }
ohair@286: 
ohair@286:     public <T> T getPort(QName portName, Class<T> portInterface, WebServiceFeature... features) {
ohair@286:         if (portName == null || portInterface == null)
ohair@286:             throw new IllegalArgumentException();
mkos@408:         WSDLService tWsdlService = this.wsdlService;
ohair@286:         if (tWsdlService == null) {
ohair@286:             // assigning it to local variable and not setting it back to this.wsdlService intentionally
ohair@286:             // as we don't want to include the service instance with information gathered from sei
ohair@286:             tWsdlService = getWSDLModelfromSEI(portInterface);
ohair@286:             //still null? throw error need wsdl metadata to create a proxy
ohair@286:             if (tWsdlService == null) {
ohair@286:                 throw new WebServiceException(ProviderApiMessages.NO_WSDL_NO_PORT(portInterface.getName()));
ohair@286:             }
ohair@286: 
ohair@286:         }
mkos@408:         WSDLPort portModel = getPortModel(tWsdlService, portName);
ohair@286:         return getPort(portModel.getEPR(), portName, portInterface, new WebServiceFeatureList(features));
ohair@286:     }
ohair@286: 
ohair@286:     public <T> T getPort(EndpointReference epr, Class<T> portInterface, WebServiceFeature... features) {
ohair@286:         return getPort(WSEndpointReference.create(epr),portInterface,features);
ohair@286:     }
ohair@286: 
ohair@286:     public <T> T getPort(WSEndpointReference wsepr, Class<T> portInterface, WebServiceFeature... features) {
ohair@286:         //get the portType from SEI, so that it can be used if EPR does n't have endpointName
alanb@368:         WebServiceFeatureList featureList = new WebServiceFeatureList(features);
alanb@368:         QName portTypeName = RuntimeModeler.getPortTypeName(portInterface, getMetadadaReader(featureList, portInterface.getClassLoader()));
ohair@286:         //if port name is not specified in EPR, it will use portTypeName to get it from the WSDL model.
ohair@286:         QName portName = getPortNameFromEPR(wsepr, portTypeName);
alanb@368:         return getPort(wsepr,portName,portInterface, featureList);
ohair@286:     }
ohair@286: 
ohair@286:     protected <T> T getPort(WSEndpointReference wsepr, QName portName, Class<T> portInterface,
ohair@286:                           WebServiceFeatureList features) {
ohair@286:         ComponentFeature cf = features.get(ComponentFeature.class);
ohair@286:         if (cf != null && !Target.STUB.equals(cf.getTarget())) {
ohair@286:             throw new IllegalArgumentException();
ohair@286:         }
alanb@368:         ComponentsFeature csf = features.get(ComponentsFeature.class);
alanb@368:         if (csf != null) {
alanb@368:             for (ComponentFeature cfi : csf.getComponentFeatures()) {
alanb@368:                 if (!Target.STUB.equals(cfi.getTarget()))
alanb@368:                     throw new IllegalArgumentException();
alanb@368:             }
alanb@368:         }
ohair@286:         features.addAll(this.features);
ohair@286: 
ohair@286:         SEIPortInfo spi = addSEI(portName, portInterface, features);
ohair@286:         return createEndpointIFBaseProxy(wsepr,portName,portInterface,features, spi);
ohair@286:     }
ohair@286: 
alanb@368:     @Override
ohair@286:     public <T> T getPort(Class<T> portInterface, WebServiceFeature... features) {
ohair@286:         //get the portType from SEI
alanb@368:         QName portTypeName = RuntimeModeler.getPortTypeName(portInterface, getMetadadaReader(new WebServiceFeatureList(features), portInterface.getClassLoader()));
mkos@408:         WSDLService tmpWsdlService = this.wsdlService;
alanb@368:         if (tmpWsdlService == null) {
ohair@286:             // assigning it to local variable and not setting it back to this.wsdlService intentionally
ohair@286:             // as we don't want to include the service instance with information gathered from sei
alanb@368:             tmpWsdlService = getWSDLModelfromSEI(portInterface);
ohair@286:             //still null? throw error need wsdl metadata to create a proxy
alanb@368:             if(tmpWsdlService == null) {
ohair@286:                 throw new WebServiceException(ProviderApiMessages.NO_WSDL_NO_PORT(portInterface.getName()));
ohair@286:             }
ohair@286:         }
ohair@286:         //get the first port corresponding to the SEI
mkos@408:         WSDLPort port = tmpWsdlService.getMatchingPort(portTypeName);
alanb@368:         if (port == null) {
alanb@368:             throw new WebServiceException(ClientMessages.UNDEFINED_PORT_TYPE(portTypeName));
alanb@368:         }
ohair@286:         QName portName = port.getName();
ohair@286:         return getPort(portName, portInterface,features);
ohair@286:     }
ohair@286: 
ohair@286:     public <T> T getPort(Class<T> portInterface) throws WebServiceException {
ohair@286:         return getPort(portInterface, EMPTY_FEATURES);
ohair@286:     }
ohair@286: 
ohair@286:     public void addPort(QName portName, String bindingId, String endpointAddress) throws WebServiceException {
ohair@286:         if (!ports.containsKey(portName)) {
ohair@286:             BindingID bid = (bindingId == null) ? BindingID.SOAP11_HTTP : BindingID.parse(bindingId);
ohair@286:             ports.put(portName,
ohair@286:                     new PortInfo(this, (endpointAddress == null) ? null :
ohair@286:                             EndpointAddress.create(endpointAddress), portName, bid));
ohair@286:         } else
ohair@286:             throw new WebServiceException(DispatchMessages.DUPLICATE_PORT(portName.toString()));
ohair@286:     }
ohair@286: 
ohair@286: 
ohair@286:     public <T> Dispatch<T> createDispatch(QName portName, Class<T>  aClass, Service.Mode mode) throws WebServiceException {
ohair@286:         return createDispatch(portName, aClass, mode, EMPTY_FEATURES);
ohair@286:     }
ohair@286: 
ohair@286:     @Override
ohair@286:     public <T> Dispatch<T> createDispatch(QName portName, WSEndpointReference wsepr, Class<T> aClass, Service.Mode mode, WebServiceFeature... features) {
ohair@286:         return createDispatch(portName, wsepr, aClass, mode, new WebServiceFeatureList(features));
ohair@286:     }
ohair@286: 
ohair@286:     public <T> Dispatch<T> createDispatch(QName portName, WSEndpointReference wsepr, Class<T> aClass, Service.Mode mode, WebServiceFeatureList features) {
ohair@286:         PortInfo port = safeGetPort(portName);
ohair@286: 
ohair@286:         ComponentFeature cf = features.get(ComponentFeature.class);
ohair@286:         if (cf != null && !Target.STUB.equals(cf.getTarget())) {
ohair@286:             throw new IllegalArgumentException();
ohair@286:         }
alanb@368:         ComponentsFeature csf = features.get(ComponentsFeature.class);
alanb@368:         if (csf != null) {
alanb@368:             for (ComponentFeature cfi : csf.getComponentFeatures()) {
alanb@368:                 if (!Target.STUB.equals(cfi.getTarget()))
alanb@368:                     throw new IllegalArgumentException();
alanb@368:             }
alanb@368:         }
ohair@286:         features.addAll(this.features);
ohair@286: 
ohair@286:         BindingImpl binding = port.createBinding(features, null, null);
ohair@286:         binding.setMode(mode);
ohair@286:         Dispatch<T> dispatch = Stubs.createDispatch(port, this, binding, aClass, mode, wsepr);
ohair@286:         serviceInterceptor.postCreateDispatch((WSBindingProvider) dispatch);
ohair@286:         return dispatch;
ohair@286:     }
ohair@286: 
ohair@286:     public <T> Dispatch<T> createDispatch(QName portName, Class<T> aClass, Service.Mode mode, WebServiceFeature... features) {
ohair@286:         return createDispatch(portName, aClass, mode, new WebServiceFeatureList(features));
ohair@286:     }
ohair@286: 
ohair@286:     public <T> Dispatch<T> createDispatch(QName portName, Class<T> aClass, Service.Mode mode, WebServiceFeatureList features) {
ohair@286:         WSEndpointReference wsepr = null;
ohair@286:         boolean isAddressingEnabled = false;
ohair@286:         AddressingFeature af = features.get(AddressingFeature.class);
ohair@286:         if (af == null) {
ohair@286:             af = this.features.get(AddressingFeature.class);
ohair@286:         }
ohair@286:         if (af != null && af.isEnabled())
ohair@286:             isAddressingEnabled = true;
ohair@286:         MemberSubmissionAddressingFeature msa = features.get(MemberSubmissionAddressingFeature.class);
ohair@286:         if (msa == null) {
ohair@286:             msa = this.features.get(MemberSubmissionAddressingFeature.class);
ohair@286:         }
ohair@286:         if (msa != null && msa.isEnabled())
ohair@286:             isAddressingEnabled = true;
ohair@286:         if(isAddressingEnabled && wsdlService != null && wsdlService.get(portName) != null) {
ohair@286:             wsepr = wsdlService.get(portName).getEPR();
ohair@286:         }
ohair@286:         return createDispatch(portName, wsepr, aClass, mode, features);
ohair@286:     }
ohair@286: 
ohair@286:     public <T> Dispatch<T> createDispatch(EndpointReference endpointReference, Class<T> type, Service.Mode mode, WebServiceFeature... features) {
ohair@286:         WSEndpointReference wsepr = new WSEndpointReference(endpointReference);
ohair@286:         QName portName = addPortEpr(wsepr);
ohair@286:         return createDispatch(portName, wsepr, type, mode, features);
ohair@286:     }
ohair@286: 
ohair@286:     /**
ohair@286:      * Obtains {@link PortInfo} for the given name, with error check.
ohair@286:      */
ohair@286:     public
ohair@286:     @NotNull
ohair@286:     PortInfo safeGetPort(QName portName) {
ohair@286:         PortInfo port = ports.get(portName);
ohair@286:         if (port == null) {
ohair@286:             throw new WebServiceException(ClientMessages.INVALID_PORT_NAME(portName, buildNameList(ports.keySet())));
ohair@286:         }
ohair@286:         return port;
ohair@286:     }
ohair@286: 
ohair@286:     private StringBuilder buildNameList(Collection<QName> names) {
ohair@286:         StringBuilder sb = new StringBuilder();
ohair@286:         for (QName qn : names) {
ohair@286:             if (sb.length() > 0) sb.append(',');
ohair@286:             sb.append(qn);
ohair@286:         }
ohair@286:         return sb;
ohair@286:     }
ohair@286: 
ohair@286:     public EndpointAddress getEndpointAddress(QName qName) {
ohair@286:         PortInfo p = ports.get(qName);
ohair@286:         return p != null ? p.targetEndpoint : null;
ohair@286:     }
ohair@286: 
ohair@286:     public Dispatch<Object> createDispatch(QName portName, JAXBContext jaxbContext, Service.Mode mode) throws WebServiceException {
ohair@286:         return createDispatch(portName, jaxbContext, mode, EMPTY_FEATURES);
ohair@286:     }
ohair@286: 
ohair@286:     @Override
ohair@286:     public Dispatch<Object> createDispatch(QName portName, WSEndpointReference wsepr, JAXBContext jaxbContext, Service.Mode mode, WebServiceFeature... features) {
ohair@286:         return createDispatch(portName, wsepr, jaxbContext, mode, new WebServiceFeatureList(features));
ohair@286:     }
ohair@286: 
ohair@286:     protected Dispatch<Object> createDispatch(QName portName, WSEndpointReference wsepr, JAXBContext jaxbContext, Service.Mode mode, WebServiceFeatureList features) {
ohair@286:         PortInfo port = safeGetPort(portName);
ohair@286: 
ohair@286:         ComponentFeature cf = features.get(ComponentFeature.class);
ohair@286:         if (cf != null && !Target.STUB.equals(cf.getTarget())) {
ohair@286:             throw new IllegalArgumentException();
ohair@286:         }
alanb@368:         ComponentsFeature csf = features.get(ComponentsFeature.class);
alanb@368:         if (csf != null) {
alanb@368:             for (ComponentFeature cfi : csf.getComponentFeatures()) {
alanb@368:                 if (!Target.STUB.equals(cfi.getTarget()))
alanb@368:                     throw new IllegalArgumentException();
alanb@368:             }
alanb@368:         }
ohair@286:         features.addAll(this.features);
ohair@286: 
ohair@286:         BindingImpl binding = port.createBinding(features, null, null);
ohair@286:         binding.setMode(mode);
ohair@286:         Dispatch<Object> dispatch = Stubs.createJAXBDispatch(
ohair@286:                 port, binding, jaxbContext, mode,wsepr);
ohair@286:          serviceInterceptor.postCreateDispatch((WSBindingProvider)dispatch);
ohair@286:          return dispatch;
ohair@286:     }
ohair@286: 
ohair@286:     @Override
ohair@286:     public @NotNull Container getContainer() {
ohair@286:         return container;
ohair@286:     }
ohair@286: 
ohair@286:     public Dispatch<Object> createDispatch(QName portName, JAXBContext jaxbContext, Service.Mode mode, WebServiceFeature... webServiceFeatures) {
ohair@286:         return createDispatch(portName, jaxbContext, mode, new WebServiceFeatureList(webServiceFeatures));
ohair@286:     }
ohair@286: 
ohair@286:     protected Dispatch<Object> createDispatch(QName portName, JAXBContext jaxbContext, Service.Mode mode, WebServiceFeatureList features) {
ohair@286:         WSEndpointReference wsepr = null;
ohair@286:         boolean isAddressingEnabled = false;
ohair@286:         AddressingFeature af = features.get(AddressingFeature.class);
ohair@286:         if (af == null) {
ohair@286:             af = this.features.get(AddressingFeature.class);
ohair@286:         }
ohair@286:         if (af != null && af.isEnabled())
ohair@286:             isAddressingEnabled = true;
ohair@286:         MemberSubmissionAddressingFeature msa = features.get(MemberSubmissionAddressingFeature.class);
ohair@286:         if (msa == null) {
ohair@286:             msa = this.features.get(MemberSubmissionAddressingFeature.class);
ohair@286:         }
ohair@286:         if (msa != null && msa.isEnabled())
ohair@286:             isAddressingEnabled = true;
ohair@286:         if(isAddressingEnabled && wsdlService != null && wsdlService.get(portName) != null) {
ohair@286:             wsepr = wsdlService.get(portName).getEPR();
ohair@286:         }
ohair@286:         return createDispatch(portName, wsepr, jaxbContext, mode, features);
ohair@286:     }
ohair@286: 
ohair@286:     public Dispatch<Object> createDispatch(EndpointReference endpointReference, JAXBContext context, Service.Mode mode, WebServiceFeature... features) {
ohair@286:         WSEndpointReference wsepr = new WSEndpointReference(endpointReference);
ohair@286:         QName portName = addPortEpr(wsepr);
ohair@286:         return createDispatch(portName, wsepr, context, mode, features);
ohair@286:     }
ohair@286: 
ohair@286:     private QName addPortEpr(WSEndpointReference wsepr) {
ohair@286:         if (wsepr == null)
ohair@286:             throw new WebServiceException(ProviderApiMessages.NULL_EPR());
ohair@286:         QName eprPortName = getPortNameFromEPR(wsepr, null);
ohair@286:         //add Port, if it does n't exist;
ohair@286:         // TODO: what if it has different epr address?
ohair@286:         {
ohair@286:             PortInfo portInfo = new PortInfo(this, (wsepr.getAddress() == null) ? null : EndpointAddress.create(wsepr.getAddress()), eprPortName,
ohair@286:                     getPortModel(wsdlService, eprPortName).getBinding().getBindingId());
ohair@286:             if (!ports.containsKey(eprPortName)) {
ohair@286:                 ports.put(eprPortName, portInfo);
ohair@286:             }
ohair@286:         }
ohair@286:         return eprPortName;
ohair@286:     }
ohair@286: 
ohair@286:     /**
ohair@286:      *
ohair@286:      * @param wsepr EndpointReference from which portName will be extracted.
ohair@286:      *      If EndpointName ( port name) is null in EPR, then it will try to get if from WSDLModel using portType QName
ohair@286:      * @param portTypeName
ohair@286:      *          should be null in dispatch case
ohair@286:      *          should be non null in SEI case
ohair@286:      * @return
ohair@286:      *      port name from EPR after validating various metadat elements.
ohair@286:      *      Also if service instance does n't have wsdl,
ohair@286:      *      then it gets the WSDL metadata from EPR and builds wsdl model.
ohair@286:      */
ohair@286:     private QName getPortNameFromEPR(@NotNull WSEndpointReference wsepr, @Nullable QName portTypeName) {
ohair@286:         QName portName;
ohair@286:         WSEndpointReference.Metadata metadata = wsepr.getMetaData();
ohair@286:         QName eprServiceName = metadata.getServiceName();
ohair@286:         QName eprPortName = metadata.getPortName();
ohair@286:         if ((eprServiceName != null ) && !eprServiceName.equals(serviceName)) {
ohair@286:             throw new WebServiceException("EndpointReference WSDL ServiceName differs from Service Instance WSDL Service QName.\n"
ohair@286:                     + " The two Service QNames must match");
ohair@286:         }
ohair@286:         if (wsdlService == null) {
ohair@286:             Source eprWsdlSource = metadata.getWsdlSource();
ohair@286:             if (eprWsdlSource == null) {
ohair@286:                 throw new WebServiceException(ProviderApiMessages.NULL_WSDL());
ohair@286:             }
ohair@286:             try {
mkos@408:                 WSDLModel eprWsdlMdl = parseWSDL(new URL(wsepr.getAddress()), eprWsdlSource, null);
ohair@286:                 wsdlService = eprWsdlMdl.getService(serviceName);
ohair@286:                 if (wsdlService == null)
ohair@286:                     throw new WebServiceException(ClientMessages.INVALID_SERVICE_NAME(serviceName,
ohair@286:                             buildNameList(eprWsdlMdl.getServices().keySet())));
ohair@286:             } catch (MalformedURLException e) {
ohair@286:                 throw new WebServiceException(ClientMessages.INVALID_ADDRESS(wsepr.getAddress()));
ohair@286:             }
ohair@286:         }
ohair@286:         portName = eprPortName;
ohair@286: 
ohair@286:         if (portName == null && portTypeName != null) {
ohair@286:             //get the first port corresponding to the SEI
mkos@408:             WSDLPort port = wsdlService.getMatchingPort(portTypeName);
ohair@286:             if (port == null)
ohair@286:                 throw new WebServiceException(ClientMessages.UNDEFINED_PORT_TYPE(portTypeName));
ohair@286:             portName = port.getName();
ohair@286:         }
ohair@286:         if (portName == null)
ohair@286:             throw new WebServiceException(ProviderApiMessages.NULL_PORTNAME());
ohair@286:         if (wsdlService.get(portName) == null)
ohair@286:             throw new WebServiceException(ClientMessages.INVALID_EPR_PORT_NAME(portName, buildWsdlPortNames()));
ohair@286: 
ohair@286:         return portName;
ohair@286: 
ohair@286:     }
ohair@286: 
mkos@384:     private <T> T createProxy(final Class<T> portInterface, final InvocationHandler pis) {
mkos@384: 
mkos@384:         // When creating the proxy, use a ClassLoader that can load classes
mkos@384:         // from both the interface class and also from this classes
mkos@384:         // classloader. This is necessary when this code is used in systems
mkos@384:         // such as OSGi where the class loader for the interface class may
mkos@384:         // not be able to load internal JAX-WS classes like
mkos@384:         // "WSBindingProvider", but the class loader for this class may not
mkos@384:         // be able to load the interface class.
mkos@384:         final ClassLoader loader = getDelegatingLoader(portInterface.getClassLoader(),
mkos@384:                 WSServiceDelegate.class.getClassLoader());
mkos@384: 
mkos@384:         // accessClassInPackage privilege needs to be granted ...
mkos@384:         RuntimePermission perm = new RuntimePermission("accessClassInPackage.com.sun." + "xml.internal.*");
mkos@384:         PermissionCollection perms = perm.newPermissionCollection();
mkos@384:         perms.add(perm);
mkos@384: 
mkos@384:         return AccessController.doPrivileged(
mkos@384:                 new PrivilegedAction<T>() {
mkos@384:                     @Override
mkos@384:                     public T run() {
mkos@384:                         Object proxy = Proxy.newProxyInstance(loader,
mkos@384:                                 new Class[]{portInterface, WSBindingProvider.class, Closeable.class}, pis);
mkos@384:                         return portInterface.cast(proxy);
mkos@384:                     }
mkos@384:                 },
mkos@384:                 new AccessControlContext(
mkos@384:                         new ProtectionDomain[]{
mkos@384:                                 new ProtectionDomain(null, perms)
mkos@384:                         })
mkos@384:         );
mkos@384:     }
mkos@384: 
mkos@408:     private WSDLService getWSDLModelfromSEI(final Class sei) {
ohair@286:         WebService ws = AccessController.doPrivileged(new PrivilegedAction<WebService>() {
ohair@286:             public WebService run() {
ohair@286:                 return (WebService) sei.getAnnotation(WebService.class);
ohair@286:             }
ohair@286:         });
ohair@286:         if (ws == null || ws.wsdlLocation().equals(""))
ohair@286:             return null;
ohair@286:         String wsdlLocation = ws.wsdlLocation();
ohair@286:         wsdlLocation = JAXWSUtils.absolutize(JAXWSUtils.getFileOrURLName(wsdlLocation));
ohair@286:         Source wsdl = new StreamSource(wsdlLocation);
mkos@408:         WSDLService service = null;
ohair@286: 
ohair@286:         try {
ohair@286:             URL url = wsdl.getSystemId() == null ? null : new URL(wsdl.getSystemId());
mkos@408:             WSDLModel model = parseWSDL(url, wsdl, sei);
ohair@286:             service = model.getService(this.serviceName);
ohair@286:             if (service == null)
ohair@286:                 throw new WebServiceException(
ohair@286:                         ClientMessages.INVALID_SERVICE_NAME(this.serviceName,
ohair@286:                                 buildNameList(model.getServices().keySet())));
ohair@286:         } catch (MalformedURLException e) {
ohair@286:             throw new WebServiceException(ClientMessages.INVALID_WSDL_URL(wsdl.getSystemId()));
ohair@286:         }
ohair@286:         return service;
ohair@286:     }
ohair@286: 
ohair@286:     public QName getServiceName() {
ohair@286:         return serviceName;
ohair@286:     }
ohair@286: 
ohair@286:     public Class getServiceClass() {
ohair@286:         return serviceClass;
ohair@286:     }
ohair@286: 
ohair@286:     public Iterator<QName> getPorts() throws WebServiceException {
ohair@286:         // KK: the spec seems to be ambigous about whether
ohair@286:         // this returns ports that are dynamically added or not.
ohair@286:         return ports.keySet().iterator();
ohair@286:     }
ohair@286: 
alanb@368:     @Override
ohair@286:     public URL getWSDLDocumentLocation() {
ohair@286:         if(wsdlService==null)   return null;
ohair@286:         try {
ohair@286:             return new URL(wsdlService.getParent().getLocation().getSystemId());
ohair@286:         } catch (MalformedURLException e) {
ohair@286:             throw new AssertionError(e); // impossible
ohair@286:         }
ohair@286:     }
ohair@286: 
mkos@384:     private <T> T createEndpointIFBaseProxy(@Nullable WSEndpointReference epr, QName portName, Class<T> portInterface,
ohair@286:                                             WebServiceFeatureList webServiceFeatures, SEIPortInfo eif) {
ohair@286:         //fail if service doesnt have WSDL
alanb@368:         if (wsdlService == null) {
ohair@286:             throw new WebServiceException(ClientMessages.INVALID_SERVICE_NO_WSDL(serviceName));
alanb@368:         }
ohair@286: 
ohair@286:         if (wsdlService.get(portName)==null) {
ohair@286:             throw new WebServiceException(
ohair@286:                 ClientMessages.INVALID_PORT_NAME(portName,buildWsdlPortNames()));
ohair@286:         }
ohair@286: 
mkos@384:         BindingImpl binding = eif.createBinding(webServiceFeatures, portInterface);
ohair@286:         InvocationHandler pis = getStubHandler(binding, eif, epr);
ohair@286: 
mkos@384:         T proxy = createProxy(portInterface, pis);
mkos@384: 
ohair@286:         if (serviceInterceptor != null) {
ohair@286:             serviceInterceptor.postCreateProxy((WSBindingProvider)proxy, portInterface);
ohair@286:         }
ohair@286:         return proxy;
ohair@286:     }
ohair@286: 
ohair@286:     protected InvocationHandler getStubHandler(BindingImpl binding, SEIPortInfo eif, @Nullable WSEndpointReference epr) {
ohair@286:         return new SEIStub(eif, binding, eif.model, epr);
ohair@286:     }
ohair@286: 
ohair@286:     /**
ohair@286:      * Lists up the port names in WSDL. For error diagnostics.
ohair@286:      */
ohair@286:     private StringBuilder buildWsdlPortNames() {
ohair@286:         Set<QName> wsdlPortNames = new HashSet<QName>();
mkos@408:         for (WSDLPort port : wsdlService.getPorts()) {
ohair@286:             wsdlPortNames.add(port.getName());
alanb@368:         }
ohair@286:         return buildNameList(wsdlPortNames);
ohair@286:     }
ohair@286: 
ohair@286:     /**
ohair@286:      * Obtains a {@link WSDLPortImpl} with error check.
ohair@286:      *
ohair@286:      * @return guaranteed to be non-null.
ohair@286:      */
mkos@408:     public @NotNull WSDLPort getPortModel(WSDLService wsdlService, QName portName) {
mkos@408:         WSDLPort port = wsdlService.get(portName);
ohair@286:         if (port == null)
ohair@286:             throw new WebServiceException(
ohair@286:                 ClientMessages.INVALID_PORT_NAME(portName,buildWsdlPortNames()));
ohair@286:         return port;
ohair@286:     }
ohair@286: 
ohair@286:     /**
ohair@286:      * Contributes to the construction of {@link WSServiceDelegate} by filling in
ohair@286:      * {@link SEIPortInfo} about a given SEI (linked from the {@link Service}-derived class.)
ohair@286:      */
ohair@286:     //todo: valid port in wsdl
ohair@286:     private SEIPortInfo addSEI(QName portName, Class portInterface, WebServiceFeatureList features) throws WebServiceException {
ohair@286:         boolean ownModel = useOwnSEIModel(features);
ohair@286:         if (ownModel) {
ohair@286:             // Create a new model and do not cache it
ohair@286:             return createSEIPortInfo(portName, portInterface, features);
ohair@286:         }
ohair@286: 
ohair@286:         SEIPortInfo spi = seiContext.get(portName);
ohair@286:         if (spi == null) {
ohair@286:             spi = createSEIPortInfo(portName, portInterface, features);
ohair@286:             seiContext.put(spi.portName, spi);
ohair@286:             ports.put(spi.portName, spi);
ohair@286:         }
ohair@286:         return spi;
ohair@286:     }
ohair@286: 
ohair@286:     public SEIModel buildRuntimeModel(QName serviceName, QName portName, Class portInterface, WSDLPort wsdlPort, WebServiceFeatureList features) {
ohair@286:                 DatabindingFactory fac = DatabindingFactory.newInstance();
ohair@286:                 DatabindingConfig config = new DatabindingConfig();
ohair@286:                 config.setContractClass(portInterface);
ohair@286:                 config.getMappingInfo().setServiceName(serviceName);
ohair@286:                 config.setWsdlPort(wsdlPort);
ohair@286:                 config.setFeatures(features);
ohair@286:                 config.setClassLoader(portInterface.getClassLoader());
ohair@286:                 config.getMappingInfo().setPortName(portName);
mkos@384:                 config.setWsdlURL(wsdlURL);
alanb@368:         // if ExternalMetadataFeature present, ExternalMetadataReader will be created ...
alanb@368:         config.setMetadataReader(getMetadadaReader(features, portInterface.getClassLoader()));
alanb@368: 
ohair@286:                 com.sun.xml.internal.ws.db.DatabindingImpl rt = (com.sun.xml.internal.ws.db.DatabindingImpl)fac.createRuntime(config);
ohair@286: 
ohair@286:                 return rt.getModel();
ohair@286:     }
ohair@286: 
alanb@368:     private MetadataReader getMetadadaReader(WebServiceFeatureList features, ClassLoader classLoader) {
alanb@368:         if (features == null) return null;
alanb@368:         com.oracle.webservices.internal.api.databinding.ExternalMetadataFeature ef =
alanb@368:                 features.get(com.oracle.webservices.internal.api.databinding.ExternalMetadataFeature.class);
alanb@368:         // TODO-Miran: would it be necessary to disable secure xml processing?
alanb@368:         if (ef != null)
alanb@368:             return ef.getMetadataReader(classLoader, false);
alanb@368:         return null;
alanb@368:     }
alanb@368: 
ohair@286:     private SEIPortInfo createSEIPortInfo(QName portName, Class portInterface, WebServiceFeatureList features) {
mkos@408:         WSDLPort wsdlPort = getPortModel(wsdlService, portName);
ohair@286:         SEIModel model = buildRuntimeModel(serviceName, portName, portInterface, wsdlPort, features);
ohair@286: 
ohair@286:         return new SEIPortInfo(this, portInterface, (SOAPSEIModel) model, wsdlPort);
ohair@286:     }
ohair@286: 
ohair@286:     private boolean useOwnSEIModel(WebServiceFeatureList features) {
ohair@286:         return features.contains(UsesJAXBContextFeature.class);
ohair@286:     }
ohair@286: 
mkos@408:     public WSDLService getWsdlService() {
ohair@286:         return wsdlService;
ohair@286:     }
ohair@286: 
alanb@368:     static class DaemonThreadFactory implements ThreadFactory {
alanb@368:         @Override
ohair@286:         public Thread newThread(Runnable r) {
ohair@286:             Thread daemonThread = new Thread(r);
ohair@286:             daemonThread.setDaemon(Boolean.TRUE);
ohair@286:             return daemonThread;
ohair@286:         }
ohair@286:     }
ohair@286: 
ohair@286:     protected static final WebServiceFeature[] EMPTY_FEATURES = new WebServiceFeature[0];
ohair@286: 
ohair@286:     private static ClassLoader getDelegatingLoader(ClassLoader loader1, ClassLoader loader2) {
ohair@286:         if (loader1 == null) return loader2;
ohair@286:         if (loader2 == null) return loader1;
ohair@286:         return new DelegatingLoader(loader1, loader2);
ohair@286:     }
ohair@286: 
alanb@368:     private static final class DelegatingLoader extends ClassLoader {
alanb@368:         private final ClassLoader loader;
ohair@286: 
alanb@368:         @Override
alanb@368:         public int hashCode() {
alanb@368:             final int prime = 31;
alanb@368:             int result = 1;
alanb@368:             result = prime * result
alanb@368:                     + ((loader == null) ? 0 : loader.hashCode());
alanb@368:             result = prime * result
alanb@368:                     + ((getParent() == null) ? 0 : getParent().hashCode());
alanb@368:             return result;
alanb@368:         }
ohair@286: 
alanb@368:         @Override
alanb@368:         public boolean equals(Object obj) {
alanb@368:             if (this == obj)
alanb@368:                 return true;
alanb@368:             if (obj == null)
alanb@368:                 return false;
alanb@368:             if (getClass() != obj.getClass())
alanb@368:                 return false;
alanb@368:             DelegatingLoader other = (DelegatingLoader) obj;
alanb@368:             if (loader == null) {
alanb@368:                 if (other.loader != null)
alanb@368:                     return false;
alanb@368:             } else if (!loader.equals(other.loader))
alanb@368:                 return false;
alanb@368:             if (getParent() == null) {
alanb@368:                 if (other.getParent() != null)
alanb@368:                     return false;
alanb@368:             } else if (!getParent().equals(other.getParent()))
alanb@368:                 return false;
alanb@368:             return true;
alanb@368:         }
ohair@286: 
alanb@368:         DelegatingLoader(ClassLoader loader1, ClassLoader loader2) {
alanb@368:             super(loader2);
alanb@368:             this.loader = loader1;
alanb@368:         }
alanb@368: 
alanb@368:         protected Class findClass(String name) throws ClassNotFoundException {
alanb@368:             return loader.loadClass(name);
alanb@368:         }
alanb@368: 
alanb@368:         protected URL findResource(String name) {
alanb@368:             return loader.getResource(name);
alanb@368:         }
ohair@286:     }
ohair@286: }