JStatefulFactory.java

package org.objectweb.jonas_ejb.container;

import java.rmi.RemoteException;

import javax.ejb.EJBException;
import javax.ejb.SessionBean;
import javax.ejb.TimerService;

import org.objectweb.jonas_ejb.deployment.api.SessionDesc;
import org.objectweb.jonas_ejb.deployment.api.SessionStatefulDesc;
import org.objectweb.jonas_ejb.lib.EJBInvocation;

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

public class JStatefulFactory extends JSessionFactory {

    JStatefulPool statefulPool;

    public JStatefulFactory(SessionStatefulDesc dd, JContainer cont, JStatefulPool sfp) {
        super((SessionDesc) dd, cont);
        TraceEjb.interp.log(BasicLevel.DEBUG, "");
        isSynchro = javax.ejb.SessionSynchronization.class.isAssignableFrom(beanclass);
        isStateful = true;
        statefulPool = sfp;
    }

    // ---------------------------------------------------------------
    // BeanFactory implementation
    // ---------------------------------------------------------------

    public int getPoolSize() {
        return 0; // TODO
    }

    public void reduceCache() {
    }

    public void initInstancePool() {
    }
    
    // ---------------------------------------------------------------
    // preInvoke / postInvoke
    // ---------------------------------------------------------------

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

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

    public void postInvoke(RequestCtx rctx) {
        TraceEjb.interp.log(BasicLevel.DEBUG, "");
        super.postInvoke(rctx);
    }

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

    public TimerService getTimerService() {
        throw new EJBException("No TimerService for Stateful Session beans");
    }

    public JSessionSwitch createNewSession() throws RemoteException {
        TraceEjb.interp.log(BasicLevel.DEBUG, "");
        JStatefulSwitch bs = new JStatefulSwitch(this, statefulPool);
        return bs;
    }

    public JSessionContext getJContext(JSessionSwitch ss) {
        TraceEjb.interp.log(BasicLevel.DEBUG, "");
        JStatefulContext bctx = null;
        try {
            bctx = createNewInstance(ss);
        } catch (Exception e) {
            throw new EJBException("Cannot create a new instance " + e);
        }
        return bctx;
    }

    // ---------------------------------------------------------------
    // private methods
    // ---------------------------------------------------------------

    private JStatefulContext createNewInstance(JSessionSwitch ss) throws Exception {
        TraceEjb.interp.log(BasicLevel.DEBUG, "");
        // create the bean instance
        SessionBean bean = null;
        try {
            bean = (SessionBean) beanclass.newInstance();
        } catch (InstantiationException e) {
            TraceEjb.logger.log(BasicLevel.ERROR, ejbname + " cannot instantiate session bean");
            throw e;
        } catch (IllegalAccessException e) {
            TraceEjb.logger.log(BasicLevel.ERROR, ejbname + " cannot instantiate session bean");
            throw e;
        }
        // create a new StatefulContext and bind it to the instance
        JStatefulContext bctx = new JStatefulContext(this, bean, isSynchro);
        bean.setSessionContext(bctx);
        bctx.setState(1);
        return bctx;
    }

}

---