JHome.java

package org.objectweb.jonas_ejb.container;

import java.rmi.NoSuchObjectException;
import java.rmi.RemoteException;

import javax.ejb.EJBHome;
import javax.ejb.EJBMetaData;
import javax.ejb.Handle;
import javax.ejb.HomeHandle;
import javax.ejb.RemoveException;
import javax.naming.NamingException;
import javax.rmi.PortableRemoteObject;

import org.objectweb.carol.util.configuration.CarolCurrentConfiguration;
import org.objectweb.carol.util.csiv2.SasHelper;

import org.objectweb.jonas_ejb.deployment.api.BeanDesc;
import org.objectweb.jonas_ejb.lib.EJBInvocation;
import org.objectweb.jonas_ejb.deployment.api.EntityDesc;
import org.objectweb.jonas_ejb.deployment.api.SessionDesc;
import org.objectweb.jonas_ejb.deployment.api.SessionStatelessDesc;
import org.objectweb.jonas_ejb.svc.JHomeHandleIIOP;
import org.objectweb.jonas_ejb.svc.JMetaData;

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

public abstract class JHome extends PortableRemoteObject implements EJBHome {

    protected JMetaData ejbMetaData = null;
    protected BeanDesc dd;
    protected JFactory bf;
    protected boolean unregistered = true;

    public JHome(BeanDesc dd, JFactory bf) throws RemoteException {
        TraceEjb.interp.log(BasicLevel.DEBUG, "JHome constructor");
        this.dd = dd;
        this.bf = bf;
    }

    // ---------------------------------------------------------------
    // EJBHome Implementation
    // ---------------------------------------------------------------

    public EJBMetaData getEJBMetaData() throws RemoteException {

        TraceEjb.interp.log(BasicLevel.DEBUG, "JHome getEJBMetaData");

        /*
         * try/catch block is commented because the encapsulated code don't
         * throw a RemoteException
         * If the code changes and throws a such exception, let's think
         * to uncomment it
         *
         * try {
         */
        if (ejbMetaData == null) {

            if (dd instanceof SessionDesc) {
                boolean isSession = true;
                boolean isStatelessSession = (dd instanceof SessionStatelessDesc);
                Class primaryKeyClass = null;
                ejbMetaData = new JMetaData(this, dd.getHomeClass(), dd.getRemoteClass(), isSession, isStatelessSession, primaryKeyClass);
          } else if (dd instanceof EntityDesc) {
              boolean isSession = false;
              boolean isStatelessSession = false;
              Class primaryKeyClass = ((EntityDesc) dd).getPrimaryKeyClass();
              ejbMetaData = new JMetaData(this, dd.getHomeClass(), dd.getRemoteClass(), isSession, isStatelessSession, primaryKeyClass);
          }
        }
        return ejbMetaData;
        /*
         * } catch (RemoteException e) {
         * // check if rmi exception mapping is needed - if yes the method rethrows it
         * RmiUtility.rethrowRmiException(e);
         * // if not, throws the exception just as it is
         * throw e;
         * }
         */
    }

    public HomeHandle getHomeHandle() throws java.rmi.RemoteException {
        TraceEjb.interp.log(BasicLevel.DEBUG, "");

        /*
         * try/catch block is commented because the encapsulated code don't
         * throw a RemoteException
         * If the code changes and throws a such exception, let's think
         * to uncomment it
         *
         * try {
         */
        // for iiop, a specific interoperable Handle is created with the use of
        // HandleDelegate
        String protocol = CarolCurrentConfiguration.getCurrent().getCurrentRMIName();
        TraceEjb.interp.log(BasicLevel.DEBUG, "Current protocol=" + protocol);

        if (protocol.equals("iiop")) {
            return new JHomeHandleIIOP(this, bf.myClassLoader());
        } else {
            return new JHomeHandle(dd.getJndiName());
        }

        /*
         * } catch (RemoteException e) {
         * // check if rmi exception mapping is needed - if yes the method  rethrows it
         * RmiUtility.rethrowRmiException(e);
         * // if not, throws the exception just as it is
         * throw e;
         * }
         */
    }

    public abstract void remove(Handle handle) throws RemoteException, RemoveException;

    public abstract void remove(Object primaryKey) throws RemoteException, RemoveException;

    // ---------------------------------------------------------------
    // other public methods
    // ---------------------------------------------------------------

    protected void register() throws NamingException {
        TraceEjb.interp.log(BasicLevel.DEBUG, "");
        String name = dd.getJndiName();

        // register in registry
        SasHelper.rebind(name, this, dd.getSasComponent());

        unregistered = false;
    }

    protected void unregister() throws NamingException {
        TraceEjb.interp.log(BasicLevel.DEBUG, "");
        String name = dd.getJndiName();
        // unregister in default InitialContext
        bf.getInitialContext().unbind(name);

        try {
            PortableRemoteObject.unexportObject(this);
        } catch (NoSuchObjectException e) {
            TraceEjb.interp.log(BasicLevel.ERROR, "unexportObject(JHome) failed: " + e);
        }
        unregistered = true;
    }

    public String getJndiName() {
        return dd.getJndiName();
    }

    public RequestCtx preInvoke(int txa) throws RemoteException {
        TraceEjb.interp.log(BasicLevel.DEBUG, "");
        return bf.preInvokeRemote(txa);
    }

     public void checkSecurity(EJBInvocation ejbInv) {
         TraceEjb.interp.log(BasicLevel.DEBUG, "");
         bf.checkSecurity(ejbInv);
     }

    public void postInvoke(RequestCtx rctx) throws RemoteException {
        TraceEjb.interp.log(BasicLevel.DEBUG, "");
        bf.postInvokeRemote(rctx);
    }

    public BeanDesc getDd() {
        return dd;
    }
    public JFactory getBf() {
        return bf;
    }
}

---