JServiceEndpointHome.java

package org.objectweb.jonas_ejb.container;

import java.rmi.RemoteException;
import java.util.HashMap;
import java.util.Map;

import javax.ejb.EJBException;
import javax.naming.Context;
import javax.naming.NamingException;
import javax.naming.Reference;
import javax.naming.StringRefAddr;
import javax.xml.namespace.QName;

import org.apache.axis.AxisFault;
import org.apache.axis.MessageContext;
import org.apache.axis.handlers.ServiceInvocation;

import org.objectweb.jonas_ejb.deployment.api.MethodDesc;
import org.objectweb.jonas_ejb.deployment.api.SessionStatelessDesc;
import org.objectweb.jonas_ejb.lib.BeanNaming;
import org.objectweb.jonas_ejb.lib.EJBInvocation;

import org.objectweb.jonas.common.Log;

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

public abstract class JServiceEndpointHome {

    protected static Logger logger = Log.getLogger(Log.JONAS_WS_EJBPROVIDER_PREFIX);
    protected static Logger lognaming = Log.getLogger(Log.JONAS_NAMING_PREFIX);

    protected SessionStatelessDesc dd;

    protected JFactory bf;

    // The static table of all JServiceEndpointHome objects
    protected static Map sehomeList = new HashMap();

    public JServiceEndpointHome(SessionStatelessDesc dd, JStatelessFactory bf) {
        logger.log(BasicLevel.DEBUG, "");
        this.dd = dd;
        this.bf = bf;
    }
    
    protected void register() throws NamingException {
        logger.log(BasicLevel.DEBUG, "");
        String name = dd.getJndiServiceEndpointName();

        // Keep it in the static list for later retrieving.
        sehomeList.put(name, this);

        Reference ref = new Reference("org.objectweb.jonas_ejb.container.JServiceEndpointHome",
                "org.objectweb.jonas_ejb.container.HomeFactory", null);
        ref.add(new StringRefAddr("bean.name", name));
        bf.getInitialContext().rebind(name, ref);
    }

    protected void unregister() throws NamingException {
        logger.log(BasicLevel.DEBUG, "");
        String name = dd.getJndiServiceEndpointName();
        // unregister in default InitialContext
        bf.getInitialContext().unbind(name);
        // remove from the static list
        sehomeList.remove(name);
    }

    public static JServiceEndpointHome getSEHome(String beanName) {
        logger.log(BasicLevel.DEBUG, "");
        JServiceEndpointHome seh = (JServiceEndpointHome) sehomeList.get(beanName);
        return seh;
    }

    public JServiceEndpoint create() throws RemoteException {
        TraceEjb.interp.log(BasicLevel.DEBUG, "");
        RequestCtx rctx = bf.preInvoke(MethodDesc.TX_NOT_SET);
        bf.checkSecurity(null);
        JStatelessSwitch bs = null;
        try {
            bs = (JStatelessSwitch) ((JStatelessFactory) bf).createEJB();
        } catch (javax.ejb.AccessLocalException e) {
            throw new EJBException("Security Exception thrown by an enterprise Bean", e);
        } catch (EJBException e) {
            rctx.sysExc = e;
            throw e;
        } catch (RuntimeException e) {
            rctx.sysExc = e;
            throw new EJBException("RuntimeException thrown by an enterprise Bean", e);
        } catch (Error e) {
            rctx.sysExc = e;
            throw new EJBException("Error thrown by an enterprise Bean" + e);
        } catch (RemoteException e) {
            rctx.sysExc = e;
            throw new EJBException("Remote Exception raised:", e);
        } finally {
            bf.postInvoke(rctx);
        }
        return bs.getServiceEndpoint();
    }

    public Context setCompCtx() {
        lognaming.log(BasicLevel.DEBUG, "");
        return bf.setComponentContext();
    }
    
    public void resetCompCtx(Context ctx) {
        if (lognaming.isLoggable(BasicLevel.DEBUG)) {
            lognaming.log(BasicLevel.DEBUG, "reset ctx:" + ctx);
        }
        bf.resetComponentContext(ctx);
    }
    
    public void checkSecurity(MessageContext msgContext) {

        EJBInvocation ejb = new EJBInvocation();
        String qname = null;
        QName  q = null;
        try {
            ServiceInvocation si = new ServiceInvocation(msgContext);
            qname = si.getMethodName();
            q = new QName(qname);
            ejb.methodPermissionSignature = BeanNaming.getSignature(bf.getEJBName(), msgContext.getOperationByQName(q).getMethod());
        } catch (AxisFault e ) {
           // error during getting the operation from the message
           // not possible to check the security
           if (lognaming.isLoggable(BasicLevel.WARN ))
                lognaming.log(BasicLevel.WARN, "can't retreive the operation from message...can not check the security");
           return;
        }
           
        bf.checkSecurity(ejb);
    }
    public abstract JServiceEndpoint createServiceEndpointObject() throws RemoteException;

    
}

---