Examples of WebServiceEndpoint


Examples of com.sun.enterprise.config.serverbeans.WebServiceEndpoint

        try {
            // set message in history size
            ConfigBean bean = getWSEPBean(event, false);
            if (bean instanceof WebServiceEndpoint) {
                WebServiceEndpoint wsep = (WebServiceEndpoint) bean;
                WebServiceEndpoint oWsep =
                    (WebServiceEndpoint) getWSEPBean(event, true);

                // monitoring level
                String newMonitoring = wsep.getMonitoring();
                String oldMonitoring = oWsep.getMonitoring();

                // history size
                int historySize = 25;

                // end point name
                String epName = wsep.getName();

                String hs = wsep.getMaxHistorySize();
                if (hs != null) {
                    historySize = Integer.parseInt(hs);
                }

                // application id
                String appId = getApplicationId(wsep);

                // message trace manager
                MessageTraceMgr traceMgr = MessageTraceMgr.getInstance();

                // monitoring level changed
                if ( (newMonitoring != null) && (oldMonitoring != null)
                        && (!newMonitoring.equals(oldMonitoring)) ) {

                    // monitoring level is changed to HIGH
                    if ("HIGH".equalsIgnoreCase(newMonitoring)) {
                        traceMgr.enable(appId, epName, historySize);

                    // monitoirng level is changed from HIGH to LOW or OFF
                    } else if ("HIGH".equalsIgnoreCase(oldMonitoring)) {
                        traceMgr.disable(appId, epName);
                    }
                } else {
                    // old history size
                    String oldHs = oWsep.getMaxHistorySize();
                    int oldHistorySize = 0;
                    if (oldHs != null) {
                        oldHistorySize = Integer.parseInt(oldHs);
                    }

                    // history size has changed and monitoring level is HIGH
                    if ((historySize != oldHistorySize)
                            && ("HIGH".equalsIgnoreCase(newMonitoring))) {

                        traceMgr.setMessageHistorySize(appId, epName,
                                                        historySize);
                    }
                }
                   
                AppServWSMonitorLifeCycleProvider aplifeProv =
                    new AppServWSMonitorLifeCycleProvider();
                aplifeProv.reconfigureMonitoring(wsep, appId,
                MonitoringLevel.instance(oldMonitoring),
                MonitoringLevel.instance(newMonitoring));
               
                // Check for jbiEnabled Flag
                boolean jbiEnabledFlag = wsep.isJbiEnabled();
                boolean oldJbiEnabledSetting =oWsep.isJbiEnabled();
                if(jbiEnabledFlag  != oldJbiEnabledSetting) {
                    String endpointURI = WebServiceMgrBackEnd.getManager().
                              getEndpointURI(getApplicationId(wsep) + "#" + epName);
                    if(endpointURI != null && (ServiceEngineRtObjectFactory.getInstance().getFacade() != null)) {
                        ServiceEngineRtObjectFactory.getInstance().
View Full Code Here

Examples of com.sun.enterprise.config.serverbeans.WebServiceEndpoint

             throws AdminEventListenerException {

        try {
            ConfigBean bean = getWSEPBean(event, false);
            if (bean instanceof WebServiceEndpoint) {
                WebServiceEndpoint wsep = (WebServiceEndpoint) bean;
                int historySize = 25;
                String epName = wsep.getName();
                String appId = getApplicationId(wsep);

                String hs = wsep.getMaxHistorySize();
                if (hs != null) {
                    historySize = Integer.parseInt(hs);
                }

                // monitoring level
                String newMonitoring = wsep.getMonitoring();

                if ("HIGH".equalsIgnoreCase(newMonitoring)) {
                    // enables message trace for this endpoint
                    MessageTraceMgr traceMgr = MessageTraceMgr.getInstance();
                    traceMgr.enable(appId, epName, historySize);
                }

                AppServWSMonitorLifeCycleProvider aplifeProv =
                    new AppServWSMonitorLifeCycleProvider();
                aplifeProv.reconfigureMonitoring(wsep, appId,
                MonitoringLevel.instance("OFF"),
                MonitoringLevel.instance(wsep.getMonitoring()));
            }
        } catch (Exception e) {
            throw new AdminEventListenerException(e);
        }
    }
View Full Code Here

Examples of com.sun.enterprise.config.serverbeans.WebServiceEndpoint

            _logger.log(Level.FINE, msg);
            return null;
        }
       
        TransformationRule[] tRules = null;
        WebServiceEndpoint wsep = null;
        if (cb instanceof  J2eeApplication) {
            wsep = ((J2eeApplication)cb).getWebServiceEndpointByName(wsepName);
        } else if (cb instanceof EjbModule) {
            wsep = ((EjbModule)cb).getWebServiceEndpointByName(wsepName);
        } else if (cb instanceof WebModule) {
            wsep = ((WebModule)cb).getWebServiceEndpointByName(wsepName);
        else {
            return null;
        }
        if (wsep != null) {
            tRules = wsep.getTransformationRule();
        }
        for(int index=0; index < tRules.length; index++) {
            retList.add(oNameMap.get(tRules[index].getName()));
        }
        return retList;
View Full Code Here

Examples of com.sun.enterprise.deployment.WebServiceEndpoint

        Model model = wscompile.getProcessor().getModel();

        Collection endpoints = webService.getEndpoints();
        for(Iterator eIter = endpoints.iterator(); eIter.hasNext();) {
            WebServiceEndpoint nextEndpoint = (WebServiceEndpoint) eIter.next();

            if( !nextEndpoint.hasHandlers() ) {
                continue;
            }

            Port port = wsUtil.getPortFromModel(model,
                                                nextEndpoint.getWsdlPort());
            if( port == null ) {
                throw new IllegalStateException("Model port for endpoint " +
                                                nextEndpoint.getEndpointName() +
                                                " not found");
            }
           
            List handlerChain = nextEndpoint.getHandlers();
            HandlerChainInfo modelHandlerChain =
                port.getServerHCI();
            List handlerInfoList = new ArrayList();

            // Insert an container handler as the first element.
            // This is needed to perform method authorization checks.
            HandlerInfo preHandler = rpcFactory.createHandlerInfo();
            String handlerClassName = nextEndpoint.implementedByEjbComponent() ?
                "com.sun.enterprise.webservice.EjbContainerPreHandler" :
                "com.sun.enterprise.webservice.ServletPreHandler";
            preHandler.setHandlerClassName(handlerClassName);
            handlerInfoList.add(preHandler);

            // Collect all roles defined on each handler and set them on
            // handler chain. NOTE : There is a bit of a mismatch here between
            // 109 and JAXRPC.  JAXRPC only defines roles at the handler chain
            // level, whereas 109 descriptors put roles at the handler level.
            Collection soapRoles = new HashSet();           

            for(Iterator hIter = handlerChain.iterator(); hIter.hasNext();) {
                WebServiceHandler nextHandler =
                    (WebServiceHandler) hIter.next();
                HandlerInfo handlerInfo = createHandlerInfo(nextHandler);
                handlerInfoList.add(handlerInfo);
                soapRoles.addAll(nextHandler.getSoapRoles());
            }

            // Insert a container handler as the last element in the chain.
            HandlerInfo postHandler = rpcFactory.createHandlerInfo();
            handlerClassName = nextEndpoint.implementedByEjbComponent() ?
                "com.sun.enterprise.webservice.EjbContainerPostHandler" :
                "com.sun.enterprise.webservice.ServletPostHandler";
            postHandler.setHandlerClassName(handlerClassName);
            handlerInfoList.add(postHandler);
View Full Code Here

Examples of com.sun.enterprise.deployment.WebServiceEndpoint

        Model model = wscompile.getProcessor().getModel();

        Collection endpoints = webService.getEndpoints();

        for(Iterator iter = endpoints.iterator(); iter.hasNext(); ) {
            WebServiceEndpoint next = (WebServiceEndpoint) iter.next();
            Service service = wsUtil.getServiceForPort(model,
                                                       next.getWsdlPort());
            if( service == null ) {
                service = (Service) model.getServices().next();

                System.out.println("Warning : Can't find Service for Endpoint '"
                                   + next.getEndpointName() + "' Port '" +
                                   next.getWsdlPort() + "'");

                System.out.println("Defaulting to "+ service.getName());
            }

            QName serviceName = service.getName();

            next.setServiceNamespaceUri(serviceName.getNamespaceURI());
            next.setServiceLocalPart(serviceName.getLocalPart());

            Port port = wsUtil.getPortFromModel(model, next.getWsdlPort());
            if( port == null ) {
                String msg = "Can't find model port for endpoint "
                    + next.getEndpointName() + " with wsdl-port " +
                    next.getWsdlPort();
                throw new IllegalStateException(msg);
            }

            // If port has a tie class name property, use it.  Otherwise,
            // use naming convention to derive tie class name.  If there
            // are multiple ports per SEI(binding), then the property then
            // the TIE_CLASS_NAME property will be available.  In that case,
            // a separate tie and stub are generated per port. 
            String tieClassName = (String)
                port.getProperty(ModelProperties.PROPERTY_TIE_CLASS_NAME);
            if( tieClassName == null ) {
                tieClassName = next.getServiceEndpointInterface() + "_Tie";
            }
            next.setTieClassName(tieClassName);

            if( next.implementedByWebComponent() ) {
                wsUtil.updateServletEndpointRuntime(next);
            } else {
                wsUtil.validateEjbEndpoint(next);
            }

            String endpointAddressUri = next.getEndpointAddressUri();
            if( endpointAddressUri == null ) {
                String msg = "Endpoint address uri must be set for endpoint " +
                    next.getEndpointName();
                throw new IllegalStateException(msg);
            } else if( endpointAddressUri.indexOf("*") >= 0 ) {
                String msg = "Endpoint address uri " + endpointAddressUri +
                    " for endpoint " + next.getEndpointName() +
                    " is invalid. It must not contain the '*' character";
                throw new IllegalStateException(msg);
            } else if( endpointAddressUri.endsWith("/") ) {
                String msg = "Endpoint address uri " + endpointAddressUri +
                    " for endpoint " + next.getEndpointName() +
                    " is invalid. It must not end with '/'";
                throw new IllegalStateException(msg);
            }
        }
    }
View Full Code Here

Examples of com.sun.enterprise.deployment.WebServiceEndpoint

        }

        String epSubtree = epPath + "/__container$publishing$subctx/";

        String epAppName = null;
        WebServiceEndpoint wse = endpoint.getDescriptor();
        if (wse != null) {
            BundleDescriptor bd = wse.getBundleDescriptor();
            if (bd != null) {
                Application app = bd.getApplication();
                if (app != null) {
                    epAppName = app.getRegistrationName();
                }
View Full Code Here

Examples of com.sun.enterprise.deployment.WebServiceEndpoint

                ((EjbRuntimeEndpointInfo)epInfo).getWebServiceContext();
        if (context != null) {
            context.setUserPrincipal(null);       
        }
       
        WebServiceEndpoint endpoint = epInfo.getEndpoint();
        boolean authenticated = false;
       
        String method = hreq.getMethod();
        if( method.equals("GET") || !endpoint.hasAuthMethod() ) {
            return true;
        }
       
        WebPrincipal webPrincipal = null;
        String endpointName = endpoint.getEndpointName();
       
        if( endpoint.hasBasicAuth() ) {
            String rawAuthInfo = hreq.getHeader(AUTHORIZATION_HEADER);
            if (rawAuthInfo==null) {
                sendAuthenticationEvents(false, hreq.getRequestURI(), null);
                return false;
            }
View Full Code Here

Examples of com.sun.enterprise.deployment.WebServiceEndpoint

        Transformer transformer = templates.newTransformer();


        // WSDL is associated with webservice, but url is endpoint-specific,
        // so let WebService choose which endpoint to use.
        WebServiceEndpoint endpointForImport =
            webService.pickEndpointForRelativeImports();
        URL root= wsi.getWebServerRootURL(endpointForImport.isSecure());
        URL finalWsdlUrl = endpointForImport.composeFinalWsdlUrl(root);
       
        int wsdlImportNum = 0;
        for(Iterator iter = wsdlRelativeImports.iterator(); iter.hasNext();){
            Import next = (Import) iter.next();
            transformer.setParameter
                (WSDL_IMPORT_NAMESPACE_PARAM_NAME + wsdlImportNum,
                 next.getNamespace());
           
            // Convert each relative import into an absolute import, using
            // the final wsdl's Url as the context
            URL relativeUrl  = new URL(finalWsdlUrl, next.getLocation());
            transformer.setParameter
                (WSDL_IMPORT_LOCATION_PARAM_NAME + wsdlImportNum, relativeUrl);
           
            wsdlImportNum++;
        }

        int schemaImportNum = 0;
        for(Iterator iter = schemaRelativeImports.iterator(); iter.hasNext();){
            Import next = (Import) iter.next();
            transformer.setParameter
                (SCHEMA_IMPORT_NAMESPACE_PARAM_NAME + schemaImportNum,
                 next.getNamespace());
           
            // Convert each relative import into an absolute import, using
            // the final wsdl's Url as the context
            URL relativeUrl  = new URL(finalWsdlUrl, next.getLocation());
            transformer.setParameter
                (SCHEMA_IMPORT_LOCATION_PARAM_NAME + schemaImportNum,
                 relativeUrl);
           
            schemaImportNum++;
        }       

        int wsdlIncludeNum = 0;
        for(Iterator iter = wsdlIncludes.iterator(); iter.hasNext();){
            Import next = (Import) iter.next();
            URL relativeUrl  = new URL(finalWsdlUrl, next.getLocation());
            transformer.setParameter
                (WSDL_INCLUDE_LOCATION_PARAM_NAME + wsdlIncludeNum, relativeUrl);           
            wsdlIncludeNum++;
        }

        int schemaIncludeNum = 0;
        for(Iterator iter = schemaIncludes.iterator(); iter.hasNext();){
            Import next = (Import) iter.next();
            URL relativeUrl  = new URL(finalWsdlUrl, next.getLocation());
            transformer.setParameter
                (SCHEMA_INCLUDE_LOCATION_PARAM_NAME + schemaIncludeNum,
                 relativeUrl);           
            schemaIncludeNum++;
        }       

        int endpointNum = 0;
        for(Iterator iter = endpointsCopy.iterator(); iter.hasNext();) {
            WebServiceEndpoint next = (WebServiceEndpoint) iter.next();

            // Get a URL for the root of the webserver, where the host portion
            // is a canonical host name.  Since this will be used to compose the
            // endpoint address that is written into WSDL, it's better to use
            // hostname as opposed to IP address.
            // The protocol and port will be based on whether the endpoint
            // has a transport guarantee of INTEGRAL or CONFIDENTIAL.
            // If yes, https will be used.  Otherwise, http will be used.
            URL rootURL = wsi.getWebServerRootURL(next.isSecure());

            URL actualAddress = next.composeEndpointAddress(rootURL);

            transformer.setParameter(ENDPOINT_ADDRESS_PARAM_NAME + endpointNum,
                                     actualAddress.toExternalForm());

            String endpointType = next.implementedByEjbComponent() ?
                "EJB" : "Servlet";

            deploymentLogger.log(Level.INFO,
                                 "enterprise.deployment.endpoint.registration",
                       new Object[] { endpointType,
                                      next.getEndpointName(), actualAddress });
           
            endpointNum++;
        }

        transformer.transform(XsltWsdlDocument, new StreamResult(outputStream));
View Full Code Here

Examples of com.sun.enterprise.deployment.WebServiceEndpoint

            schemaIncludeNum++;
        }

        int endpointNum = 0;
        for(Iterator iter = endpoints.iterator(); iter.hasNext();) {
            WebServiceEndpoint endpoint = (WebServiceEndpoint) iter.next();

            if( !endpoint.hasWsdlPort() ) {
                throw new Exception("No WSDL port specified for endpoint " +
                                    endpoint.getEndpointName());
            }
            if( !endpoint.hasServiceName() ) {
                throw new Exception("Runtime settings error.  Cannot find " +
                                    "service name for endpoint " +
                                    endpoint.getEndpointName());
            }
           
            String actualAddressParam =
                ENDPOINT_ADDRESS_PARAM_NAME + endpointNum;

            writer.write("<xsl:param name=\"" + actualAddressParam + "\"/>\n");
       
            writer.write("<xsl:template match=\"/\"><xsl:apply-templates mode=\"copy\"/></xsl:template>\n");
       
            writer.write("<xsl:template match=\"wsdl:definitions[@targetNamespace='");
            writer.write(endpoint.getServiceName().getNamespaceURI());
            writer.write("']/wsdl:service[@name='");
            writer.write(endpoint.getServiceName().getLocalPart());
            writer.write("']/wsdl:port[@name='");
            writer.write(endpoint.getWsdlPort().getLocalPart());
            writer.write("']/"+endpoint.getSoapAddressPrefix()+":address\" mode=\"copy\">");
            writer.write("<"+endpoint.getSoapAddressPrefix()+":address><xsl:attribute name=\"location\"><xsl:value-of select=\"$" + actualAddressParam + "\"/>");
            writer.write("</xsl:attribute></"+endpoint.getSoapAddressPrefix()+":address></xsl:template>");

            endpointNum++;
        }

        writer.write("<xsl:template match=\"@*|node()\" mode=\"copy\"><xsl:copy><xsl:apply-templates select=\"@*\" mode=\"copy\"/><xsl:apply-templates mode=\"copy\"/></xsl:copy></xsl:template>\n");
View Full Code Here

Examples of com.sun.enterprise.deployment.WebServiceEndpoint

     * instance associated with this XMLNode
     *
     * @param descriptor the new descriptor
     */
    public void addDescriptor(Object descriptor) {   
        WebServiceEndpoint endpoint = (WebServiceEndpoint) descriptor;
        WebService webService = (WebService) getDescriptor();
        webService.addEndpoint(endpoint);
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.