JAXRServiceImpl.java

package org.objectweb.jonas.jaxr;

import java.util.Hashtable;
import java.util.Iterator;
import java.util.Map;
import java.util.Properties;
import java.util.Vector;

import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

import org.objectweb.jonas.common.JProp;
import org.objectweb.jonas.common.Log;
import org.objectweb.jonas.common.PropDump;
import org.objectweb.jonas.service.AbsServiceImpl;
import org.objectweb.jonas.service.ServiceException;

import org.objectweb.util.monolog.api.BasicLevel;
import org.objectweb.util.monolog.api.Logger;


public class JAXRServiceImpl extends AbsServiceImpl implements JAXRService {

    private Context ictx = null;
    private static Logger logger = null;

    private Vector factoryNames = new Vector();

    private Map bindedFactories = new Hashtable();
    public static final String FACTORIES = "jonas.service.jaxr.factories";

    public static final String CLASS = "jonas.service.jaxr.class";

    private static final String JNDI_NAME = "jaxr.jndi.name";

    protected void doInit(Context ctx) throws ServiceException {
        // get logger for this service
        logger = Log.getLogger(Log.JONAS_JAXR_PREFIX);

        //Get the inital Context
        try {
            ictx = new InitialContext();
        } catch (NamingException e) {
            logger.log(BasicLevel.ERROR, "Cannot create initial context during the jaxr service initializing");
            throw new ServiceException("Cannot create initial context during the jaxr service initializing", e);
        }

        // Get the list of the factory names
        String factories = null;
        try {
            factories = (String) ctx.lookup(FACTORIES);
        } catch (NamingException e) {
            ; // No problem if there is no value for 'factories'
        }
        if (factories != null) {
            String[] names = factories.split(", ");
            for (int i = 0; i < names.length; i++) {
                factoryNames.add(names[i].trim());
            }
        }
        logger.log(BasicLevel.DEBUG, "jaxr service initialized");

    }

    protected void doStart() throws ServiceException {
        // creates each factory
        String factoryName = null;
        for (Iterator i = factoryNames.iterator(); i.hasNext();) {
            factoryName = (String) i.next();
            try {
                JProp prop = JProp.getInstance(factoryName);
                if (logger.isLoggable(BasicLevel.DEBUG)) {
                    logger.log(BasicLevel.DEBUG, "Creating JAXR Connection Factory " + factoryName);
                }
                createJAXRConnection(prop.getConfigFileEnv());
            } catch (Exception e) {
                if (logger.isLoggable(BasicLevel.ERROR)) {
                    logger.log(BasicLevel.ERROR, "JOnAS: Cannot create jaxr factory " + factoryName + " : " + e);
                    logger.log(BasicLevel.ERROR, "Please check the " + factoryName + ".properties file");
                }
            }
        }
    }

    protected void doStop() throws ServiceException {
        removeAllJAXRConnections();
        logger.log(BasicLevel.DEBUG, "jaxr service stopped");
    }

    private void removeAllJAXRConnections() {

        for (Iterator i = bindedFactories.keySet().iterator(); i.hasNext();) {
            String name = (String) i.next();
            removeJAXRConnection(name);
        }

    }

    public void createJAXRConnection(Properties props) throws ServiceException {
        PropDump.print("These are the properties from which the jaxrService picks to construct jaxr Factories", props, logger, BasicLevel.DEBUG);

        //Factory type/jndi name must be non null
        String jndiName = props.getProperty(JNDI_NAME);

        if (jndiName == null) {
            String err = "The property '" + JNDI_NAME + "' is a required property.";
            logger.log(BasicLevel.ERROR, err);
            throw new ServiceException(err);
        }

        // Verify that jndi name not already used
        if (bindedFactories.containsKey(jndiName)) {
            String err = "There is already a factory bound with the name " + jndiName + ", please correct the provided configuration properties";
            logger.log(BasicLevel.ERROR, err);
            throw new ServiceException(err);
        }

        // Create the JAXRConnection Object
        JAXRConnection jaxrConnection = new JAXRConnection(props);

        // Bind the factory object in the naming context
        bindJAXRFactory(jndiName, jaxrConnection);

        logger.log(BasicLevel.INFO, "Mapping JAXR Connection Factory on " + jndiName);

    }

    private void bindJAXRFactory(String jndiName, JAXRConnection jaxrConnection) {
        try {
            ictx.rebind(jndiName, jaxrConnection.getReference());
            bindedFactories.put(jndiName, jaxrConnection);
        } catch (NamingException e) {
            String err = "Cannot bind jaxr factory '" + jndiName + "'";
            logger.log(BasicLevel.ERROR, err);
            throw new ServiceException(err, e);
        }
    }

    public void modifyJAXRConnection(String name, JAXRConnection jaxrc) throws ServiceException {
        // remove old Connection
        removeJAXRConnection(name);
        // create new one
        bindJAXRFactory(name, jaxrc);

        logger.log(BasicLevel.DEBUG, "JAXRConnection modified");
    }

    public void removeJAXRConnection(String name) throws ServiceException {

        // test if factory is registered
        if (!bindedFactories.containsKey(name)) {
            String err = "Unknown JAXRConnection '" + name + "'";
            logger.log(BasicLevel.ERROR, err);
            throw new ServiceException(err);
        }

        // remove from the local list
        bindedFactories.remove(name);

        // remove from the registry
        try {
            ictx.unbind(name);
        } catch (NamingException e) {
            String err = "Cannot unbind JAXR Connection '" + name + "'";
            logger.log(BasicLevel.ERROR, err);
            throw new ServiceException(err, e);
        }

        logger.log(BasicLevel.DEBUG, "JAXRConnection '" + name + "' removed");
    }

}

---