JSessionSwitch.java

package org.objectweb.jonas_ejb.container;

import java.rmi.RemoteException;

import javax.transaction.Transaction;

import org.objectweb.jonas_timer.TimerEvent;
import org.objectweb.jonas_timer.TimerEventListener;
import org.objectweb.jonas_timer.TimerManager;

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

public abstract class JSessionSwitch implements TimerEventListener {

    protected JSessionFactory bf;

    protected JSessionLocal local = null;

    protected JSessionRemote remote = null;

    protected TimerEvent mytimer = null;

    public JSessionSwitch(JSessionFactory bf) throws RemoteException {
        TraceEjb.interp.log(BasicLevel.DEBUG, "");
        this.bf = bf;

        // Create EJBObject if bean has a Remote Interface
        if (bf.getHome() != null) {
            remote = ((JSessionHome) bf.getHome()).createRemoteObject();
            remote.setSessionSwitch(this);
        }

        // Create EJBLocalObject if bean has a Local Interface
        if (bf.getLocalHome() != null) {
            local = ((JSessionLocalHome) bf.getLocalHome()).createLocalObject();
            local.setSessionSwitch(this);
        }
    }

    public JSessionLocal getLocal() {
        return local;
    }

    public JSessionRemote getRemote() {
        return remote;
    }

    public JSessionFactory getBeanFactory() {
        return bf;
    }

    public void startTimer(int timeout) {
        TraceEjb.interp.log(BasicLevel.DEBUG, "");
        mytimer = TimerManager.getInstance().addTimerMs(this, timeout, null, false);
    }

    public void stopTimer() {
        TraceEjb.interp.log(BasicLevel.DEBUG, "");
        if (mytimer != null) {
            mytimer.unset();
        }
    }
    
    public abstract JSessionContext getICtx(Transaction tx) throws RemoteException;
    public abstract void releaseICtx(Transaction tx);
    public abstract void discardICtx(Transaction tx);
    public abstract void setMustCommit(boolean mc);
    public abstract void saveBeanTx();

    public abstract void pushConnectionList();
    public abstract void popConnectionList();
    public abstract void enlistConnections(Transaction tx);
    public abstract void delistConnections(Transaction tx);
}

---