FileDocCategorySizeDatePackage
WebServiceMgrBackEnd.javaAPI DocGlassfish v2 API39876Fri May 04 22:24:40 BST 2007com.sun.enterprise.admin.wsmgmt

WebServiceMgrBackEnd

public class WebServiceMgrBackEnd extends Object
Manager MBean for web services. This enumerates the list of the web services deployed in the domain. For each web service, detailed information can be obtained.

Fields Summary
public static final String
DEFAULT_VIRTUAL_SERVER
Default virtual server, under which all the web service monitoring stats are maintained
private com.sun.enterprise.instance.AppsManager
appsMgr
PRIVATE VARIABLES
private com.sun.enterprise.admin.wsmgmt.repository.spi.RepositoryProvider
repPvdr
private com.sun.enterprise.admin.wsmgmt.repository.spi.WebServiceInfoProvider
wsInfoPvdr
private WeakHashMap
wsInfoMap
private static final String
NAME_SEPERATOR
private static WebServiceMgrBackEnd
mgrImpl
private static final Logger
_logger
private static final com.sun.enterprise.util.i18n.StringManager
_stringMgr
private static final String
LOCAL_HOST
private static final String
MINUS_ONE
private static final String
DEFAULT_ORGANIZATION
private static final String
DEFAULT_DESCRIPTION
private static final String
DEFAULT_PORT
private static final String
WEB_SERVICES_WORKAROUND_PORT
WebServices backend has changed and the WSDL file is no longer available Breaking Registry code that parses the WSDL file to locate the port This is a workaround for BETA to specify the port as -D option. This should be fixed by FCS
Constructors Summary
private WebServiceMgrBackEnd()
Default constructor for WebServiceMgrBackEnd

        try {
            repPvdr = RepositoryFactory.getRepositoryProvider();
            wsInfoPvdr = RepositoryFactory.getWebServiceInfoProvider();
        } catch (Exception e) {
            _logger.fine("WebServiceInfoProvider could not be instantiated: " +
                    e.getMessage());
            // log warning
        }
        wsInfoMap = new WeakHashMap();
        try {
            InstanceEnvironment ienv =
                    ApplicationServer.getServerContext().getInstanceEnvironment();
            appsMgr = new AppsManager(ienv);
        } catch (Exception e) {
            _logger.fine("AppsManager could not be instantiated: " +
                    e.getMessage());
            // log exception in FINE level. This excpetion should never occur.
        }
Methods Summary
public voidaddRegistryConnectionResources(java.lang.String jndiName, java.lang.String description, java.lang.String type, java.util.Map properties)
Adds registry specific resources to the domain. Adds a connector connection pool and then proceeds to add a connector resource

param
jndiName of the connector-resource that points to the registry
param
description of the connector-resource and the connector-connection -pool name
param
type of the registry {@link com.sun.appserv.management.WebServiceMgr#UDDI_KEY} {@link com.sun.appserv.management.WebServiceMgr#EBXML_KEY}
param
properties a map of key, value pair that encapsulate the properties of the connection pool that connects to the registry. Properties are {@link com.sun.appserv.management.WebServiceMgr#PUBLISH_URL_KEY} {@link com.sun.appserv.management.WebServiceMgr#QUERY_URL_KEY} {@link com.sun.appserv.management.WebServiceMgr#USERNAME_KEY} {@link com.sun.appserv.management.WebServiceMgr#PASSWORD_KEY}

        ConfigHelper configHelper = ConfigHelper.getInstanceToDeleteRegistryResources();
        configHelper.addRegistryConnectionResources(jndiName, description, type,
                properties);
public java.lang.StringgetEndpointName(java.lang.String epName)

        String[] sStrs = epName.split(NAME_SEPERATOR);
        if ( sStrs != null) {
            return sStrs[sStrs.length -1];
        } else {
            return null;
        }
public java.lang.StringgetEndpointURI(java.lang.String name)
Return WebServiceEndpointInfo for a web service.

param
name Fully qualified name of the web service
return
EndpointURI for a endpoint

        java.util.Map endpointInfoMap = getWebServiceInfoMap(name);
        if(endpointInfoMap != null)
            return (String)endpointInfoMap.get(WebServiceEndpointInfo.END_POINT_URI_KEY);
        else
            return null;
private java.util.MapgetFromCache(java.lang.String appName, java.lang.String bundleName)

        Iterator itr = wsInfoMap.entrySet().iterator();
        
        Map nMap = null;
        if (itr == null) {
            return null;
        }
        while(itr.hasNext()) {
            Map.Entry entry = (Map.Entry) itr.next();
            String fqn = (String) entry.getKey();
            WebServiceEndpointInfo wsInfo = (WebServiceEndpointInfo) entry.getValue();
            if ( isFQNMatch( fqn, appName, bundleName) ) {
                if ( nMap == null) {
                    nMap = new HashMap();
                }
                nMap.put(fqn, wsInfo.getName());
            }
        }
        return nMap;
public java.lang.StringgetFullyQualifiedName(java.lang.String appName, java.lang.String bundleName, boolean isStandAlone, java.lang.String wsName)

        
        if (isStandAlone) {
            return   appName + NAME_SEPERATOR +
                    wsName;
        } else {
            return appName + NAME_SEPERATOR + bundleName + NAME_SEPERATOR +
                    wsName;
        }
public java.lang.StringgetFullyQualifiedName(java.lang.String appName, java.lang.String bundleName, java.lang.String wsName)

        
        if (appName == null) {
            return  bundleName + NAME_SEPERATOR +
                    wsName;
        } else {
            return appName + NAME_SEPERATOR + bundleName + NAME_SEPERATOR +
                    wsName;
        }
public java.lang.StringgetFullyQualifiedName(com.sun.enterprise.webservice.monitoring.Endpoint ep)

        
        com.sun.enterprise.deployment.WebServiceEndpoint wse=ep.getDescriptor();
        String epName = null;
        if (wse != null) {
            epName = wse.getEndpointName();
        }
        BundleDescriptor bundle = wse.getBundleDescriptor();
        Application app = bundle.getApplication();
        
        String fqn = getFullyQualifiedName( app.getRegistrationName() ,
                bundle.getModuleDescriptor().getArchiveUri(),
                app.isVirtual(), epName);
        return fqn;
public java.lang.StringgetFullyQualifiedName(java.lang.String moduleID, java.lang.String wsName)

        return   moduleID + NAME_SEPERATOR + wsName;
private java.lang.StringgetHostAddress()

        try {
            java.net.InetAddress iaddr = java.net.InetAddress.getLocalHost();
            return iaddr.getHostAddress();
        } catch (Exception e) {
            return LOCAL_HOST;
        }
public static synchronized com.sun.enterprise.admin.wsmgmt.WebServiceMgrBackEndgetManager()

        if ( mgrImpl == null) {
            mgrImpl = new WebServiceMgrBackEnd();
        }
        return mgrImpl;
public java.lang.StringgetModuleName(java.lang.String epName)

        String[] sStrs = epName.split(NAME_SEPERATOR);
        if ( sStrs != null) {
            return sStrs[0];
        } else {
            return null;
        }
java.lang.StringgetPort(java.lang.String webServiceName, boolean unsecure, java.lang.String wsdlFile)

        
        String port = DEFAULT_PORT;
        // Extract web service port from the WSDL file.
        String http = (unsecure == true)? "http":"https";
        String pattern = "soap:address.*location.*"+http+":.*:[0-9][0-9][0-9][0-9]";
        Pattern soap_address_pattern = Pattern.compile(pattern);
        Matcher soap_address_matcher = soap_address_pattern.matcher(wsdlFile);
        boolean soapAddress = soap_address_matcher.find();
        if (soapAddress){
            String soap_address = soap_address_matcher.group();
            Pattern port_pattern = Pattern.compile("[0-9][0-9][0-9][0-9]");
            Matcher port_matcher = port_pattern.matcher(soap_address);
            port_matcher.find();
            port = port_matcher.group();
        } else
            port =  null;
       
        return port;
public com.sun.enterprise.admin.wsmgmt.registry.RegistryAccessObjectgetRegistryAccessObject()
Returns RegistryAccessObject; RegistryAccessObject encapsulates access to the underlying registries

return
RegistryAccessObject

        return new RegistryAccessObjectImpl();
public java.util.ListgetTransformationRuleConfigObjectNameList(java.lang.String appId, java.lang.String wsepName, java.util.Map oNameMap)

        
        if (oNameMap == null) {
            return null;
        }
        
        ArrayList retList = new ArrayList(oNameMap.size());
        ConfigContext configCtx = AdminService.getAdminService().
                getAdminContext().getAdminConfigContext();
        ConfigBean cb = null;
        
        try {
            cb = ApplicationHelper.findApplication(configCtx, appId);
        } catch( Exception e) {
            String msg = "Could not find a deployed application/module by name "
                    + appId;
            _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;
java.lang.StringgetWSDL(java.lang.String host, java.lang.String webServiceName)

        String port = DEFAULT_PORT;
        ConfigHelper ch = ConfigHelper.getInstanceToQueryRegistryLocations();
        port = ch.getInstancePort ();
        if (port == null)
            port = DEFAULT_PORT; // sanity
        
        String wsdl = null;
        String uri = null;
        WebServiceEndpointInfo wsInfo = getWebServiceInfo(webServiceName);
        
        if ( wsInfo == null) {
            // should never happen.
            throw new RuntimeException("Could not retreive WebService" +
                    "Information. Cannot publish web service  ");
        } else      {
            uri = wsInfo.getEndpointURI();
        }
        String wsdlurl = "http://" + host + ":"+ port +"/"+ uri+"?wsdl";
        try{
            URL url = new URL(wsdlurl);
            HttpURLConnection connection = (HttpURLConnection)url.openConnection();
            connection.connect();
            BufferedReader reader =
                    new BufferedReader(new InputStreamReader(connection.getInputStream()));
            StringBuffer wsdlBuf = new StringBuffer();
            String line = null;
            while((line=reader.readLine())!=null){
                wsdlBuf.append(line);
            }
            reader.close();
            wsdl = wsdlBuf.toString();
            System.out.println(wsdl);
        }catch (MalformedURLException mue){
            _logger.log (Level.WARNING, " Malformed URL for Web Service"+
                    webServiceName, mue);
        }catch (IOException ioe){
            _logger.log(Level.WARNING, " Cannot retrieve WSDL for Web Service "+
                    webServiceName, ioe);
        }
        return wsdl;
private java.lang.StringgetWSObjectNames(java.lang.String appId, java.lang.String modId, java.lang.String epName, java.lang.String ctxRoot, boolean isEjb, java.lang.String serverName)

        
        String requiredProps      =
                Util.makeRequiredProps( J2EETypes.WEB_SERVICE, epName  );
        
        String vsProps = null;
        if ( !isEjb) {
            String secPart = ctxRoot;
            if ( secPart == null) {
                Application app = null;
                try {
                    app = appsMgr.getDescriptor(appId);
                } catch (ConfigException ce) {
                    // log a warning
                    _logger.fine("The descriptor for application " + appId +
                            " could not be loaded: " + ce.getMessage());
                }
                if (app != null) {
                    WebBundleDescriptor wbd
                            = app.getWebBundleDescriptorByUri(modId);
                    if (wbd != null) {
                        secPart = wbd.getContextRoot();
                    }
                }
            }
            if (secPart == null) {
                // not getting the context root from the descriptor
                // Descriptor must not be loaded
                return null;
            }
            if (secPart.charAt(0) != '/") {
                secPart = "/" + secPart;
            }
            String compositeName="//"+ DEFAULT_VIRTUAL_SERVER + secPart;
            vsProps  = Util.makeProp( J2EETypes.WEB_MODULE, compositeName );
        } else {
            vsProps      = Util.makeProp( J2EETypes.EJB_MODULE, modId );
        }
        
        requiredProps = Util.concatenateProps(requiredProps, vsProps);
        
        String serverProp = null;
        
        if (( serverName != null) &&  ( !serverName.equals("*"))) {
            serverProp = Util.makeProp( J2EETypes.J2EE_SERVER, serverName );
        }
        
        String  props   = serverProp;
        
        if ( appId == null ) {
            appId = AMX.NULL_NAME;
        }
        final String    applicationProp = Util.makeProp(
                J2EETypes.J2EE_APPLICATION, appId );
        
        if ( props != null) {
            props   = Util.concatenateProps( props, applicationProp );
        } else {
            props = applicationProp;
        }
        
        String finalProps = Util.concatenateProps(requiredProps, props);
        
        return finalProps;
private java.lang.StringgetWebServiceEndpointContextRoot(java.lang.String wsFQN)

        
        String[] fqns = wsFQN.split(NAME_SEPERATOR);
        ConfigContext configCtx = AdminService.getAdminService().
                getAdminContext().getAdminConfigContext();
        ConfigBean cb = null;
        
        try {
            cb = ApplicationHelper.findApplication(configCtx, fqns[0]);
        } catch( Exception e) {
            String msg = "Could not find a deployed application/module by name "
                    + fqns[0] + " : " + e.getMessage();
            _logger.log(Level.FINE, msg);
            return null;
        }
        
        boolean isStandalone = false, isEjb = false;
        String appId = null, modId = null, epName = null,ctxRoot = null;
        
        if (cb instanceof  J2eeApplication) {
            assert( fqns.length == 3);
            return null;
        } else if (cb instanceof EjbModule) {
            assert( fqns.length == 2);
            return null;
        } else if (cb instanceof WebModule) {
            assert( fqns.length == 2);
            return ((WebModule)cb).getContextRoot();
        }  else {
            return null;
        }
public java.lang.StringgetWebServiceEndpointObjectNames(java.lang.Object key, java.lang.String serverName)
Returns the object names of the mbeans matching the criteria specified for WebServiceEndpoint MBeans.

param
endpointKey Fully qualified key for web service endpoint
param
serverName Name of the server instance
return
Properties of WebServiceEndpoint MBean object names.

        if ((key == null) ||  !( key instanceof String) ) {
            String msg =
                    "Key passed to WebServiceEndpointObjectNames must be of type String";
            _logger.log(Level.FINE, msg);
            return null;
        }
        
        WebServiceEndpointInfo wsInfo = getWebServiceInfo( (String)key);
        if ( wsInfo == null) {
            return null;
        } else {
            String implType = wsInfo.getServiceImplType();
            boolean isEjb = false;
            if ( implType.equals("EJB")) {
                isEjb = true;
            }
            String appName = wsInfo.getAppID();
            String modName = wsInfo.getBundleName();
            if(wsInfo.isAppStandaloneModule() == true) {
                // appId is the module name
                modName = appName;
                // J2EE application name is null for stand alone modules
                appName = null;
            }
            return getWSObjectNames(appName,
                    modName, wsInfo.getName(),
                    getWebServiceEndpointContextRoot( (String)key),isEjb, serverName);
        }
private com.sun.appserv.management.ext.wsmgmt.WebServiceEndpointInfogetWebServiceInfo(java.lang.String name)

        WebServiceEndpointInfo wsInfo = (WebServiceEndpointInfo) wsInfoMap.get(name);
        // call expired, load its descriptors
        // XXX this should be optimized
        if (wsInfo == null) {
            getWebServicesMap();
            wsInfo = (WebServiceEndpointInfo) wsInfoMap.get(name);
        }
        return wsInfo;
public java.util.MapgetWebServiceInfoMap(java.lang.String name)
Return WebServiceEndpointInfo for a web service.

param
name Fully qualified name of the web service
return
WebServiceEndpointInfo for a web service

        WebServiceEndpointInfo wsInfo = getWebServiceInfo(name);
        if (wsInfo == null) {
            return null;
        } else {
            return ((WebServiceEndpointInfoImpl)wsInfo).asMap();
        }
public java.util.MapgetWebServicesMap()
Returns a Map containing web services and the fully qualified name for each web service. This fully qualified name must be used to get more details about this web service.

return
Map of web service name and its fully qualified name

        Map wsNameMap = new HashMap();
        
        // Getting all the modules containing web service end points
        Map wsModMap = repPvdr.getWebServiceModules();
        // no modules found, return empty map
        if ( wsModMap == null ){
            return wsNameMap;
        }
        
        // If underlying Set can not be retrieved return
        // return empty map
        Set wsModSet = wsModMap.entrySet();
        if ( wsModSet == null) {
            return wsNameMap;
        }
        
        // iterate through each module and add web services to the map
        Iterator wsModItr = wsModSet.iterator();
        while (wsModItr.hasNext() ) {
            Map.Entry wsMapEntry = (Map.Entry) wsModItr.next();
            String descLoc = (String) wsMapEntry.getKey();
            Map propMap = (Map) wsMapEntry.getValue();
            List wsInfoListInMod = null;
            String appName = (String)
            propMap.get(WebServiceInfoProvider.APP_ID_PROP_NAME);
            String bundleName = (String)
            propMap.get(WebServiceInfoProvider.BUNDLE_NAME_PROP_NAME);
            
            Map nMap = getFromCache(appName, bundleName);
            if (nMap != null) {
                wsNameMap.putAll(nMap);
                continue;
            }
            
            try {
                wsInfoListInMod = wsInfoPvdr.getWebServiceInfo(descLoc,
                        propMap);
            } catch ( Exception e) {
                // log warnin
                String msg =_stringMgr.getString("ModInfoNotFound",appName
                        + " : " + e.getMessage());
                _logger.log(Level.WARNING, msg);
            }
            
            
            if ( wsInfoListInMod != null ) {
                Iterator wsInfoItrInMod = wsInfoListInMod.iterator();
                
                while (wsInfoItrInMod.hasNext() ) {
                    WebServiceEndpointInfo wsInfo =
                            (WebServiceEndpointInfo) wsInfoItrInMod.next();
                    
                    // add this web service name and its fully qualified name
                    // the map that is being returned
                    
                    String wsFQN =  getFullyQualifiedName(appName, bundleName,
                            wsInfo.isAppStandaloneModule(), wsInfo.getName());
                    wsNameMap.put(wsFQN, wsInfo.getName());
                    
                    // update the internal weak hashmap
                    updateCache(wsFQN, wsInfo);
                }
            }
        }
        return wsNameMap;
private booleanisFQNMatch(java.lang.String fqn, java.lang.String appName, java.lang.String bundleName)

        String matchFqn;
        
        if ( bundleName != null) {
            matchFqn = appName + NAME_SEPERATOR + bundleName + NAME_SEPERATOR;
        } else {
            matchFqn = appName + NAME_SEPERATOR ;
        }
        
        return ( fqn.startsWith(matchFqn));
private booleanisFQNMatch(java.lang.String fqn, java.lang.String appName)

        
        String matchFqn = appName + NAME_SEPERATOR ;
        
        return ( fqn.startsWith(matchFqn));
public java.lang.String[]listRegistryLocations()

        RegistryAccessObject rao = this.getRegistryAccessObject();
        return rao.listRegistryLocations();
public java.lang.StringmoveFileToRepository(java.lang.String curLocation, java.lang.String appId)
This method moves the transformation rule file from the curLocation (in some temp dir location) to generated/xml//
param
curLocation current temp location of rule file
param
appId application or module Id
return
the new location of the rule file.

        
        if (( curLocation == null) || ( appId == null)) {
            String msg = "Either rule location or appId passed is null "
                    + appId;
            _logger.log(Level.FINE, msg);
            throw new IllegalArgumentException();
        }
        
        String appType = null;
        ConfigContext configCtx = AdminService.getAdminService().
                getAdminContext().getAdminConfigContext();
        
        try {
            appType = ApplicationHelper.getApplicationType(configCtx, appId);
        } catch( Exception e) {
            String msg = "Could not find a deployed application/module type "
                    + appId;
            _logger.log(Level.FINE, msg);
            throw new RuntimeException(e);
        }
        
        String rootDir = System.getProperty(
                SystemPropertyConstants.INSTANCE_ROOT_PROPERTY);
        String finalLoc = null;
        
        File fin = new File(curLocation);
        if ( appType.equals(Applications.J2EE_APPLICATION) ) {
            finalLoc = rootDir + File.separator + PEFileLayout.GENERATED_DIR +
                    File.separator + PEFileLayout.XML_DIR + File.separator +
                    PEFileLayout.J2EE_APPS_DIR +
                    File.separator + appId + File.separator ;
        } else if (( appType.equals(Applications.EJB_MODULE)) ||
                ( appType.equals(Applications.WEB_MODULE) )) {
            finalLoc = rootDir + File.separator + PEFileLayout.GENERATED_DIR +
                    File.separator + PEFileLayout.XML_DIR + File.separator +
                    PEFileLayout.J2EE_MODULES_DIR +
                    File.separator + appId + File.separator;
        }
        
        
        File fout = new File(finalLoc + fin.getName());
        
        // check if the named file already exists, then choose a different name
        int fileIdx = 0;
        while ( fout.exists() ) {
            fout = new File( finalLoc + fileIdx + fin.getName());
            fileIdx++;
        }
        
        FileUtils.copy(fin, fout);
        FileUtils.liquidate(fin);
        
        return finalLoc + fin.getName();
public voidpublishToRegistry(java.lang.String[] registryLocations, java.lang.Object webServiceEndpointKey, java.util.Map optional)

        
        String webServiceName = (String)webServiceEndpointKey;  
        
        boolean published = false;
        try{
            RegistryAccessObject rao = this.getRegistryAccessObject();
            _logger.fine("WebServiceMgrBackEnd.publishToRegistry: publishing" +
                    "WebService "+webServiceName);
            
            String lbhost = (String)optional.get(WebServiceMgr.LB_HOST_KEY);
            
            if (lbhost == null){
                lbhost = getHostAddress();
                _logger.fine("WebServiceMgrBackend.publishToRegistry: Load " +
                        "Balancer Host is unspecified setting to "+ lbhost);
            }
            String wsdl = getWSDL (lbhost, webServiceName);
            if(wsdl == null){
                _logger.log(Level.SEVERE,
                        "registry.wsdl_absent_publish_failure",
                        webServiceName);
                            
                throw new RuntimeException (" Could not retreive WSDL for "+
                        webServiceName);
            }
            
            String lbport = (String)optional.get(WebServiceMgr.LB_PORT_KEY);
            String lbsslport = (String)optional.get(WebServiceMgr.LB_SECURE_PORT);
            
            if (lbport == null && lbsslport == null) {
                lbport = getPort(webServiceName, true, wsdl);
                if (lbport == null)
                    lbport = MINUS_ONE;
                lbsslport = getPort(webServiceName, false, wsdl);
                if (lbsslport == null)
                    lbsslport = MINUS_ONE;
                _logger.fine("WebServiceMgrBackend.publishToRegistry: Load " +
                        "Balancer Port Unspecified setting to default values  " +
                        "LoadBalancer Port = "+ lbport +
                        " LoadBalancer SSL Port = "+lbsslport);
            } else if (lbsslport == null){
                _logger.fine("WebServiceMgrBackend.publishToRegistry: Load " +
                        "Balancer SSL Port is unspecified setting to "+ MINUS_ONE);
                lbsslport = MINUS_ONE;
            } else if (lbport == null){
                _logger.fine("WebServiceMgrBackend.publishToRegistry: Load " +
                        "Balancer Host is unspecified setting to "+ MINUS_ONE);
                lbport = MINUS_ONE;
            }
            int ilbport = -1;
            int ilbsslport = -1;
            try{
                ilbport = Integer.valueOf(lbport);
            } catch  (NumberFormatException e){
                _logger.fine("WebServiceMgrBackend.publishToRegistry: Load " +
                        "Balancer Port is not a number. Setting to "+ MINUS_ONE);
                ilbport = -1;
            }
            try{
                if(lbsslport !=null)
                    ilbsslport = Integer.valueOf(lbsslport);
            }catch (NumberFormatException e){
                _logger.fine("WebServiceMgrBackend.publishToRegistry: Load " +
                        "Balancer SSL Port is not a number. Setting to "+ MINUS_ONE);
                ilbsslport = -1;
            }
            String categoriesList = (String)optional.get(WebServiceMgr.CATEGORIES_KEY);
            String[] categories = null;
            if (categoriesList != null){
                java.util.StringTokenizer tokenizer =
                        new java.util.StringTokenizer(categoriesList, ",");
                List<String> list = new ArrayList<String>();
                while (tokenizer.hasMoreElements()){
                    list.add((String)tokenizer.nextToken());
                }
                categories = new String[list.size()];
                categories = list.toArray(categories);
            }
            String organization = (String) optional.get(WebServiceMgr.ORGANIZATION_KEY);
            if (organization == null){
                _logger.fine("WebServiceMgrBackend.publishToRegistry: Organization " +
                        " unspecified. Setting a default organization "+
                        DEFAULT_ORGANIZATION);
                organization = DEFAULT_ORGANIZATION;
            }
            String description = (String) optional.get(WebServiceMgr.DESCRIPTION_KEY);
            if (description == null){
                _logger.fine("WebServiceMgrBackend.publishToRegistry: Web Service " +
                        " Description unspecified. Setting a default description: "+
                        DEFAULT_DESCRIPTION);
                description = DEFAULT_DESCRIPTION;
            }
            published = rao.publish(registryLocations, webServiceName, lbhost,
                    ilbport, ilbsslport, categories, organization, description, 
                    wsdl);
            if (published == false){
                String errorMessage =
                        _stringMgr.getString("WebServiceMgrBackend.PublishFailure",
                        webServiceName);
                _logger.log(Level.SEVERE, "registry.publish_failure", webServiceName);
                throw new RuntimeException(errorMessage);
            } else {
                String message =
                        _stringMgr.getString("WebServiceMgrBackend.PublishSuccess",
                        webServiceName);
                _logger.log(Level.INFO, message);
            }
        } catch (RuntimeException re){
            _logger.log(Level.SEVERE, "registry.publish_failure_exception", re);
            throw re;
        } catch (Exception e) {
            _logger.log(Level.SEVERE, "registry.publish_failure", webServiceName);
            _logger.log(Level.SEVERE, "registry.publish_failure_exception", e);
            RuntimeException r =  new RuntimeException(e);
            throw r;
        }
public voidremoveFileFromRepository(java.lang.String appId, java.lang.String epName, java.lang.String ruleName)
This method removes the transformation rule file from the repository directory.

param
appId application or module Id
param
epName End point's name
param
ruleName Transformation rule's name

        
        if (( appId == null) || ( epName == null) || (ruleName == null)) {
            String msg = "Either appId or epName or ruleName passed is null "
                    + appId;
            _logger.log(Level.FINE, msg);
            throw new IllegalArgumentException();
        }
        
        ConfigContext configCtx = AdminService.getAdminService().
                getAdminContext().getAdminConfigContext();
        
        TransformationRule tRule = null;
        try {
            tRule = ApplicationHelper.findTransformationRule(configCtx,
                    appId,epName, ruleName);
        } catch( Exception e) {
            String msg = "Could not find a deployed application/module type "
                    + appId;
            _logger.log(Level.FINE, msg);
            throw new RuntimeException(e);
        }
        
        File ruleFile = new File(tRule.getRuleFileLocation());
        FileUtils.liquidate(ruleFile);
public synchronized voidremoveFromCache(java.lang.String appName)
Removes the web service end point informationt that is cached by the Web Services Management module. This should be only used during un-deploy. The only expeced user of this method is AppServDELImpl java class.

param
appName application this being un-deployed

        
        Iterator itr = wsInfoMap.entrySet().iterator();
        
        if (itr == null) {
            return;
        }
        while(itr.hasNext()) {
            Map.Entry entry = (Map.Entry) itr.next();
            String fqn = (String) entry.getKey();
            WebServiceEndpointInfo wsInfo =
                    (WebServiceEndpointInfo) entry.getValue();
            if ( isFQNMatch( fqn, appName) ) {
                itr.remove();
            }
        }
public voidremoveRegistryConnectionResources(java.lang.String jndiNameOfRegistry)
Removes the registry specific resources from the domain. Peeks at the connector-resource element to obtain the connector-connection-pool name. Using this pool name, removes the connector-connection-pool, proceeds further to remove the connector-resource

param
jndiNameOfRegistry whose resources are to be removed from the domain

        ConfigHelper configHelper = ConfigHelper.getInstanceToDeleteRegistryResources();
        configHelper.removeRegistryConnectionResources(jndiNameOfRegistry);
        return;
public voidunpublishFromRegistry(java.lang.String[] registryLocations, java.lang.Object webServiceEndpointKey)

        
        String webServiceName = (String)webServiceEndpointKey;
        boolean unpublished = false;
        try{
            RegistryAccessObject rao = this.getRegistryAccessObject();
            _logger.fine("WebServiceMgrBackEnd.unpublishFromRegistry:" +
                    "unpublishing web service = "+ webServiceName);
            unpublished = rao.unpublishFromRegistry(registryLocations, webServiceName);
            if(unpublished == false){
                String errorMessage =
                        _stringMgr.getString("WebServiceMgrBackend.UnpublishFailure",
                        webServiceName);
                
                _logger.log(Level.SEVERE, "registry.unpublish_failure", webServiceName);
                throw new RuntimeException(errorMessage);
            } else{
                _logger.log(Level.INFO, "registry.unpublish_success", webServiceName);
            }
        } catch (RuntimeException re){
            _logger.log(Level.SEVERE, "registry.unpublish_failure_exception", re);
            throw re;
        }catch (Exception e){
            String errorMessage =
                    _stringMgr.getString("WebServiceMgrBackend.UnpublishFailure",
                    webServiceName);
            
            _logger.log(Level.SEVERE, "registry.unpublish_failure", webServiceName);
            _logger.log(Level.SEVERE, "registry.unpublish_failure_exception",e);
            throw new RuntimeException(e);
        }
private synchronized voidupdateCache(java.lang.String wsFQN, com.sun.appserv.management.ext.wsmgmt.WebServiceEndpointInfo wsInfo)

        wsInfoMap.put(wsFQN, wsInfo);