import com.sun.xml.internal.ws.api.server.WSEndpoint; //导入依赖的package包/类
public ServerTubeAssemblerContext(@Nullable SEIModel seiModel,
                                  @Nullable WSDLPort wsdlModel, @NotNull WSEndpoint endpoint,
                                  @NotNull Tube terminal, boolean isSynchronous) {
    this.seiModel = seiModel;
    this.wsdlModel = wsdlModel;
    this.endpoint = endpoint;
    this.terminal = terminal;
    // WSBinding is actually BindingImpl
    this.binding = (BindingImpl)endpoint.getBinding();
    this.isSynchronous = isSynchronous;
    this.codec = this.binding.createCodec();
}
 

import com.sun.xml.internal.ws.api.server.WSEndpoint; //导入依赖的package包/类
/**
 * Return ManagedService assertion if there is one associated with the endpoint.
 *
 * @param endpoint The endpoint. Must not be null.
 * @return The policy assertion if found. Null otherwise.
 * @throws WebServiceException If computing the effective policy of the endpoint failed.
 */
public static ManagedServiceAssertion getAssertion(WSEndpoint endpoint) throws WebServiceException {
    LOGGER.entering(endpoint);
    // getPolicyMap is deprecated because it is only supposed to be used by Metro code
    // and not by other clients.
    @SuppressWarnings("deprecation")
    final PolicyMap policyMap = endpoint.getPolicyMap();
    final ManagedServiceAssertion assertion = ManagementAssertion.getAssertion(MANAGED_SERVICE_QNAME,
            policyMap, endpoint.getServiceName(), endpoint.getPortName(), ManagedServiceAssertion.class);
    LOGGER.exiting(assertion);
    return assertion;
}
 

import com.sun.xml.internal.ws.api.server.WSEndpoint; //导入依赖的package包/类
protected HttpAdapter(WSEndpoint endpoint,
                      HttpAdapterList<? extends HttpAdapter> owner,
                      String urlPattern) {
    super(endpoint);
    this.owner = owner;
    this.urlPattern = urlPattern;

    initWSDLMap(endpoint.getServiceDefinition());
}
 

import com.sun.xml.internal.ws.api.server.WSEndpoint; //导入依赖的package包/类
@Override
public T createAdapter(String name, String urlPattern, WSEndpoint<?> endpoint) {
    T t = createHttpAdapter(name, urlPattern, endpoint);
    adapters.add(t);
    WSDLPort port = endpoint.getPort();
    if (port != null) {
        PortInfo portInfo = new PortInfo(port.getOwner().getName(),port.getName().getLocalPart(), endpoint.getImplementationClass());
        addressMap.put(portInfo, getValidPath(urlPattern));
    }
    return t;
}
 

import com.sun.xml.internal.ws.api.server.WSEndpoint; //导入依赖的package包/类
public @Override @NotNull String getEPRAddress(Packet request, WSEndpoint endpoint) {
    PortAddressResolver resolver = adapter.owner.createPortAddressResolver(getBaseAddress(), endpoint.getImplementationClass());
    String address = resolver.getAddressFor(endpoint.getServiceName(), endpoint.getPortName().getLocalPart());
    if(address==null) {
        throw new WebServiceException(WsservletMessages.SERVLET_NO_ADDRESS_AVAILABLE(endpoint.getPortName()));
    }
    return address;
}
 

import com.sun.xml.internal.ws.api.server.WSEndpoint; //导入依赖的package包/类
@Override
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;
    }
}
 

import com.sun.xml.internal.ws.api.server.WSEndpoint; //导入依赖的package包/类
protected ServerAdapter(String name, String urlPattern, WSEndpoint endpoint, ServerAdapterList owner) {
    super(endpoint, owner, urlPattern);
    this.name = name;
    // registers itself with the container
    Module module = endpoint.getContainer().getSPI(Module.class);
    if(module==null)
        LOGGER.log(Level.WARNING, "Container {0} doesn''t support {1}",
                new Object[]{endpoint.getContainer(), Module.class});
    else {
        module.getBoundEndpoints().add(this);
    }
}
 

import com.sun.xml.internal.ws.api.server.WSEndpoint; //导入依赖的package包/类
public @NotNull String getEPRAddress(Packet request, WSEndpoint endpoint) {
    //return WSHttpHandler.getRequestAddress(httpExchange);

    PortAddressResolver resolver = adapter.owner.createPortAddressResolver(getBaseAddress(), endpoint.getImplementationClass());
    String address = resolver.getAddressFor(endpoint.getServiceName(), endpoint.getPortName().getLocalPart());
    if(address==null)
        throw new WebServiceException(WsservletMessages.SERVLET_NO_ADDRESS_AVAILABLE(endpoint.getPortName()));
    return address;

}
 

import com.sun.xml.internal.ws.api.server.WSEndpoint; //导入依赖的package包/类
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;
}
 

import com.sun.xml.internal.ws.api.server.WSEndpoint; //导入依赖的package包/类
@Override
public boolean equalsProxiedInstance(WSEndpoint endpoint) {
    if (wsEndpoint == null) {
        return (endpoint == null);
    }
    return wsEndpoint.equals(endpoint);
}
 

import com.sun.xml.internal.ws.api.server.WSEndpoint; //导入依赖的package包/类
/**
 * Implements {@link WSEndpoint#create}.
 *
 * No need to take WebServiceContext implementation. When InvokerPipe is
 * instantiated, it calls InstanceResolver to set up a WebServiceContext.
 * We shall only take delegate to getUserPrincipal and isUserInRole from adapter.
 *
 * <p>
 * Nobody else should be calling this method.
 */
public static <T> WSEndpoint<T> createEndpoint(
    Class<T> implType, boolean processHandlerAnnotation, @Nullable Invoker invoker,
    @Nullable QName serviceName, @Nullable QName portName,
    @Nullable Container container, @Nullable WSBinding binding,
    @Nullable SDDocumentSource primaryWsdl,
    @Nullable Collection<? extends SDDocumentSource> metadata,
    EntityResolver resolver, boolean isTransportSynchronous) {
    return createEndpoint(implType, processHandlerAnnotation, invoker, serviceName,
                    portName, container, binding, primaryWsdl, metadata, resolver, isTransportSynchronous, true);
}
 

import com.sun.xml.internal.ws.api.server.WSEndpoint; //导入依赖的package包/类
/**
 * Implements {@link WSEndpoint#create}.
 *
 * No need to take WebServiceContext implementation. When InvokerPipe is
 * instantiated, it calls InstanceResolver to set up a WebServiceContext.
 * We shall only take delegate to getUserPrincipal and isUserInRole from adapter.
 *
 * <p>
 * Nobody else should be calling this method.
 */
public <T> WSEndpoint<T> create(
        Class<T> implType, boolean processHandlerAnnotation, @Nullable Invoker invoker,
        @Nullable QName serviceName, @Nullable QName portName,
        @Nullable Container container, @Nullable WSBinding binding,
        @Nullable SDDocumentSource primaryWsdl,
        @Nullable Collection<? extends SDDocumentSource> metadata,
        EntityResolver resolver, boolean isTransportSynchronous) {
    return create(implType, processHandlerAnnotation, invoker, serviceName,
                    portName, container, binding, primaryWsdl, metadata, resolver, isTransportSynchronous,
                    true);

}
 

import com.sun.xml.internal.ws.api.server.WSEndpoint; //导入依赖的package包/类
public ServerSchemaValidationTube(WSEndpoint endpoint, WSBinding binding,
        SEIModel seiModel, WSDLPort wsdlPort, Tube next) {
    super(binding, next);
    this.seiModel = seiModel;
    this.wsdlPort = wsdlPort;

    if (endpoint.getServiceDefinition() != null) {
        MetadataResolverImpl mdresolver = new MetadataResolverImpl(endpoint.getServiceDefinition());
        Source[] sources = getSchemaSources(endpoint.getServiceDefinition(), mdresolver);
        for(Source source : sources) {
            LOGGER.fine("Constructing service validation schema from = "+source.getSystemId());
            //printDOM((DOMSource)source);
        }
        if (sources.length != 0) {
            noValidation = false;
            sf.setResourceResolver(mdresolver);
            try {
                schema = sf.newSchema(sources);
            } catch(SAXException e) {
                throw new WebServiceException(e);
            }
            validator = schema.newValidator();
            return;
        }
    }
    noValidation = true;
    schema = null;
    validator = null;
}