JStatelessSwitch.java

package org.objectweb.jonas_ejb.container;

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

import javax.ejb.RemoveException;
import javax.transaction.SystemException;
import javax.transaction.Transaction;
import javax.xml.rpc.handler.MessageContext;

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

public class JStatelessSwitch extends JSessionSwitch {

    private JStatelessContext bctx = null;
    
    private JServiceEndpoint se = null;

    public JStatelessSwitch(JStatelessFactory bf) throws RemoteException {
        super(bf);
        TraceEjb.interp.log(BasicLevel.DEBUG, "");
        
        // Create ServiceEndpoint if defined in the bean descriptor
        if (bf.getSEHome() != null) {
            se = ((JServiceEndpointHome) bf.getSEHome()).createServiceEndpointObject();
            se.setSessionSwitch(this);
        }
    }

    // ===============================================================
    // TimerEventListener implementation
    // ===============================================================

    public synchronized void timeoutExpired(Object arg) {
        TraceEjb.logger.log(BasicLevel.WARN, "stateless session timeout expired");
        mytimer = null;
        if (bctx != null) {
            try {
                bctx.setRemoved();
                ((JStatelessFactory) bf).releaseJContext(bctx);
                bctx = null;
            } catch (RemoteException e) {
                TraceEjb.logger.log(BasicLevel.WARN, "timeout expired:" + e);
            } catch (RemoveException e) {
                TraceEjb.logger.log(BasicLevel.WARN, "timeout expired:" + e);
            }
        }
        noLongerUsed();
    }

    // ===============================================================
    // other public methods
    // ===============================================================

    public JServiceEndpoint getServiceEndpoint() {
        return se;
    }
    
    public MessageContext getMsgContext() {
        if (se == null) {
            TraceEjb.logger.log(BasicLevel.ERROR, "No ServiceEndpoint for this bean");
            return null;
        }
        return se.getMessageContext();
    }
    
    public JSessionContext getICtx(Transaction tx) throws RemoteException {
        TraceEjb.interp.log(BasicLevel.DEBUG, "");
        bctx = (JStatelessContext) ((JStatelessFactory) bf).getJContext(this);
        return bctx;
    }

    public void releaseICtx(Transaction tx) {
        TraceEjb.interp.log(BasicLevel.DEBUG, "");

        if (bctx == null) {
            return;
        }
        if (bctx.isMarkedRemoved()) {
            stopTimer();
            noLongerUsed();
        }
        ((JStatelessFactory) bf).releaseJContext(bctx);
        bctx = null;
    }

    public void discardICtx(Transaction tx) {
        TraceEjb.interp.log(BasicLevel.DEBUG, "");

        // In case getICtx failed, bctx may be null.
        if (bctx == null) {
            return;
        }

        stopTimer();
        noLongerUsed();

        ((JStatelessFactory) bf).releaseJContext(bctx);
        bctx = null;

    }

    public void noLongerUsed() {
        TraceEjb.interp.log(BasicLevel.DEBUG, "");

        // Unexport the EJBObject from the Orb
        if (remote != null) {
            try {
                remote.unexportObject();
            } catch (NoSuchObjectException e) {
                TraceEjb.logger.log(BasicLevel.ERROR, "exception: " + e);
            }
        }

        // return the SessionSwitch in the pool.
        // will be reused for another Session.
        bf.removeEJB(this);
    }

    public void setMustCommit(boolean mc) {
    }

    public void pushConnectionList() {
    }

    public void popConnectionList() {
    }

    public void enlistConnections(Transaction tx) {
    }
    public void delistConnections(Transaction tx) {
    }
    public void saveBeanTx() {
    }
}

---