JOnASEJBProvider.java

package org.objectweb.jonas.ws.axis;

import java.lang.reflect.Method;

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

import org.apache.axis.AxisFault;
import org.apache.axis.Handler;
import org.apache.axis.MessageContext;
import org.apache.axis.i18n.Messages;
import org.apache.axis.providers.java.RPCProvider;

import org.objectweb.jonas_ejb.container.JServiceEndpoint;
import org.objectweb.jonas_ejb.container.JServiceEndpointHome;

import org.objectweb.jonas.common.Log;
import org.objectweb.jonas.security.ws.SecurityContextHelper;

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

public class JOnASEJBProvider extends RPCProvider {

    private static Logger logger = null;

    public static final String OPTION_SEINTERFACENAME = "serviceEndpointInterfaceName";

    public static final String OPTION_SEJNDINAME = "serviceEndpointJndiName";

    private static InitialContext cachedContext;

    public JOnASEJBProvider() {
        super();
        logger = Log.getLogger(Log.JONAS_WS_EJBPROVIDER_PREFIX);
        logger.log(BasicLevel.DEBUG, "");
    }

    protected Object makeNewServiceObject(MessageContext msgContext, String seiName) throws Exception {
        logger.log(BasicLevel.DEBUG, seiName);
        if (seiName == null) {
            logger.log(BasicLevel.ERROR, "Service Endpoint Interface classname is null");
            // cannot find service-endpoint
            throw new AxisFault(Messages.getMessage("noOption00", OPTION_SEINTERFACENAME, msgContext.getService()
                    .getName()));
        }

        // Get ServiceEndpointHome in JNDI
        String jndiName = getStrOption(OPTION_SEJNDINAME, msgContext.getService());
        if (jndiName == null) {
            logger.log(BasicLevel.ERROR, "Service Endpoint JNDI name is null");
            throw new AxisFault("Missing parameter in service : " + OPTION_SEJNDINAME);
        }
        JServiceEndpointHome sehome = null;
        try {
            InitialContext ic = getCachedContext();
            sehome = (JServiceEndpointHome) ic.lookup(jndiName);
        } catch (NamingException ne) {
            logger.log(BasicLevel.ERROR, "Cannot lookup ServiceEndpointHome");
            throw new AxisFault("Cannot lookup ServiceEndpointHome: " + jndiName);
        }
        // Check that the object implements the SEI
        // TODO

        // Create a new ServiceEndpoint object
        JServiceEndpoint se = sehome.create();

        // Set the MessageContext that can be retrived by the bean
        se.setMessageContext(msgContext);
        return se;
    }

    protected Object invokeMethod(MessageContext msgContext, Method method, Object obj, Object[] argValues)
            throws Exception {
        logger.log(BasicLevel.DEBUG, "");
        String username = msgContext.getUsername();
        if (username != null) {
            // Do not forget to initialize the security context
            SecurityContextHelper.getInstance().login(username, msgContext.getPassword());
        }
        return super.invokeMethod(msgContext, method, obj, argValues);
    }

    protected String getServiceClassNameOptionName() {
        logger.log(BasicLevel.DEBUG, "");
        return OPTION_SEINTERFACENAME;
    }

    private String getStrOption(String optionName, Handler service) {
        String value = null;
        if (service != null) {
            value = (String) service.getOption(optionName);
        }
        if (value == null) {
            value = (String) getOption(optionName);
        }
        return value;
    }

    private InitialContext getCachedContext() throws javax.naming.NamingException {
        if (cachedContext == null) {
            cachedContext = new InitialContext();
        }
        return cachedContext;
    }

}

---