JEntityLocal.java

package org.objectweb.jonas_ejb.container;

import javax.ejb.EJBException;
import javax.ejb.EJBLocalHome;
import javax.ejb.EJBLocalObject;
import javax.ejb.RemoveException;

import org.objectweb.jonas_ejb.lib.EJBInvocation;

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

public abstract class JEntityLocal extends JLocal {

    protected JEntityFactory bf;

    protected JEntitySwitch bs;

    public JEntityLocal(JEntityFactory bf) {
        super(bf);
        TraceEjb.interp.log(BasicLevel.DEBUG, "");
        this.bf = bf;
    }

    public void setEntitySwitch(JEntitySwitch bs) {
        TraceEjb.interp.log(BasicLevel.DEBUG, "");
        this.bs = bs;
    }

    // --------------------------------------------------------------------------
    // EJBLocalObject implementation
    // remove() is implemented in the generated part.
    // --------------------------------------------------------------------------

    public abstract void remove() throws RemoveException;

    public EJBLocalHome getEJBLocalHome() {
        TraceEjb.interp.log(BasicLevel.DEBUG, "");
        return bf.getLocalHome();
    }

    public Object getPrimaryKey() {
        TraceEjb.interp.log(BasicLevel.DEBUG, "");
        if (bs == null) {
            throw new EJBException("No Primary Key yet");
        }
        return bs.getPrimaryKey();
    }

    public boolean isIdentical(EJBLocalObject obj) {
        TraceEjb.interp.log(BasicLevel.DEBUG, "");
        boolean ret = false;
        if (obj != null) {
            // Get the home class name
            String homeClassName = getEJBLocalHome().getClass().getName();
            String objHomeClassName = obj.getEJBLocalHome().getClass().getName();

            // Tests the home equality and the primary key equality
            ret = ((objHomeClassName.equals(homeClassName)) && (obj.getPrimaryKey().equals(getPrimaryKey())));
        }
        return ret;
    }

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

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

    public void postInvoke(RequestCtx rctx) {
        TraceEjb.interp.log(BasicLevel.DEBUG, "");
        try {
            bf.postInvoke(rctx);
        } finally {
            if (rctx.sysExc != null) {
                bs.discardICtx(rctx.currTx);
            } else {
                bs.releaseICtx(rctx.currTx);
            }
        }
    }
}

---