ConnectorFactory.java

package org.objectweb.jonas.jmx;

import java.util.HashSet;
import java.util.Properties;
import java.util.Set;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.naming.NameClassPair;
import javax.naming.NamingEnumeration;
import javax.rmi.PortableRemoteObject;

// JOnAS Log
import org.objectweb.jonas.common.Log;

// Monolog
import org.objectweb.util.monolog.api.Logger;
import org.objectweb.util.monolog.api.BasicLevel;
public class ConnectorFactory {

    private static String currentRMIConnectorName = null;
    private static RMIConnector rmic = null; // current RMIConnector
    private static Context context = null;
    private static Logger logger = Log.getLogger("objectweb.org.jonas.jmx");

    public static Context getContext() throws javax.naming.NamingException {
        if (context == null) {
            context = new InitialContext();
        }
        return context;
    }

    public static String getCurrentRMIConnectorName() {
        try {
            if (currentRMIConnectorName == null) { // may be not set yet
                HashSet connectorNames = (HashSet)getRMIConnectorsNames();
                if (! connectorNames.isEmpty()) {
                    // Pick up the first connector name in the list
                    String firstName = (String)connectorNames.toArray()[0];
                    setCurrentRMIConnectorName(firstName);
                } // else, currentRMIConnector rests null
            }
            return currentRMIConnectorName;
        } catch (javax.naming.NamingException ne) {
            return null;
        }
    }

    public static void setCurrentRMIConnectorName(String name) throws NamingException {
        currentRMIConnectorName = name;
        // The rmi connector name may have changed, so we lookup for the corresponding rmi connector
        lookupRMIConnector();
    }

    public static void resetCurrentRMIConnectorName() {
        currentRMIConnectorName = null;
    }

    public static Set getRMIConnectorsNames() throws javax.naming.NamingException {
        try {
            HashSet res = new HashSet();
            Context ctx = getContext();
            // looking for all object registered in this registry
            for (NamingEnumeration e = ctx.list(""); e.hasMoreElements(); ) {
                String name = ((NameClassPair)e.nextElement()).getName();
                // we select only rmi connectors (start with 'RMIConnector')
                if (name.startsWith("RMIConnector"))
                    res.add(name);
            }
            return res;
        } catch (javax.naming.NamingException ne) {
            throw new javax.naming.NamingException("Cannot enumerates the names bound in the named context: '"
                                                   +getJonasNamingServiceURL()
                                                   +"' (registry probably not launched).");
        }
    }

    public static String getJonasNamingServiceURL() {
        try {
            return (String)getContext().getEnvironment().get(Context.PROVIDER_URL);
        } catch (javax.naming.NamingException ne) {
            return ne.getMessage();
        }
    }

    public static void setNamingEnvCtx(Properties env) throws javax.naming.NamingException {
        context = new InitialContext(env);
        rmic = null;
        currentRMIConnectorName = null;
    }

    public static void setJonasNamingServiceURL(String url) throws javax.naming.NamingException {

        // Properties for the new naming context
        Properties p = new Properties();

        // Current context
        Context ctx = getContext();
        // Re-use the same values for the INITIAL_CONTEXT_FACTORY and URL_PKG_PREFIXES
        p.put(Context.INITIAL_CONTEXT_FACTORY, ctx.getEnvironment().get(Context.INITIAL_CONTEXT_FACTORY));
        p.put(Context.URL_PKG_PREFIXES, ctx.getEnvironment().get(Context.URL_PKG_PREFIXES));
        // Use the url parameter for the PROVIDER_URL property
        p.put(Context.PROVIDER_URL, url);

        try {
            context = new InitialContext(p);
        } catch (NamingException e) {
            logger.log(BasicLevel.DEBUG, "Can' create context : " + e);
            logger.log(BasicLevel.DEBUG, "Environment used :");
            logger.log(BasicLevel.DEBUG, Context.INITIAL_CONTEXT_FACTORY + " = " + p.get(Context.INITIAL_CONTEXT_FACTORY));
            logger.log(BasicLevel.DEBUG, Context.URL_PKG_PREFIXES + " = " + p.get(Context.URL_PKG_PREFIXES));
            logger.log(BasicLevel.DEBUG, Context.PROVIDER_URL + " = " + p.get(Context.PROVIDER_URL));
            throw e;
        }

        rmic = null;
        currentRMIConnectorName = null;

    }

    public static RMIConnector getRMIConnector() throws NamingException {
        if (rmic == null) {
            lookupRMIConnector();
        }
        return rmic;
    }

    public static void lookupRMIConnector() throws NamingException {
        String _currentRMIConnectorName = getCurrentRMIConnectorName();
        if (_currentRMIConnectorName != null) {
            rmic = (RMIConnector)PortableRemoteObject.narrow(getContext().lookup(_currentRMIConnectorName), RMIConnector.class);
        }
    }
}

---