JServiceEndpoint.java

package org.objectweb.jonas_ejb.container;

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

import javax.ejb.EJBException;
import javax.naming.NamingException;
import javax.rmi.PortableRemoteObject;
import javax.xml.rpc.ServiceException;
import javax.xml.rpc.handler.MessageContext;
import javax.xml.rpc.server.ServiceLifecycle;

import org.objectweb.jonas.common.Log;
import org.objectweb.jonas_ejb.deployment.api.MethodDesc;
import org.objectweb.jonas_ejb.deployment.api.SessionStatelessDesc;
import org.objectweb.jonas_ejb.lib.EJBInvocation;

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

public class JServiceEndpoint extends PortableRemoteObject implements Remote, ServiceLifecycle {

    protected static Logger logger = null;

    protected JSessionSwitch bs;

    protected JStatelessFactory bf;

    private MessageContext messageContext = null;

    public JServiceEndpoint(JStatelessFactory sf) throws RemoteException {
        super();
        logger = Log.getLogger(Log.JONAS_WS_EJBPROVIDER_PREFIX);
        logger.log(BasicLevel.DEBUG, "");
        bf = sf;
    }

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

    public void setMessageContext(MessageContext msgctx) {
        messageContext = msgctx;
    }
    
    public MessageContext getMessageContext() {
        return messageContext;
    }
    
    public void setSessionSwitch(JSessionSwitch bs) {
        logger.log(BasicLevel.DEBUG, "");
        this.bs = bs;
    }

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

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

    public void postInvoke(RequestCtx rctx) throws RemoteException {
        logger.log(BasicLevel.DEBUG, "");
        try {
            bf.postInvokeRemote(rctx);
        } finally {
            // put instance in the pool for future reuse.
            bs.releaseICtx(rctx.currTx);
        }
    }

    // --------------------------------------------------------------------
    // ServiceLifeCycle implementation
    // --------------------------------------------------------------------
    
    public void init(Object arg0) throws ServiceException {
        logger.log(BasicLevel.DEBUG, "");
    }
    
    public void destroy() {
        logger.log(BasicLevel.DEBUG, "");
        RequestCtx rctx = null;
        try {
            rctx = bf.preInvoke(MethodDesc.TX_NOT_SET);
            bf.checkSecurity(null);
        } catch (Exception e) {
            logger.log(BasicLevel.ERROR, "preInvoke failed: ", e);
            return;
        }
        try {
            JSessionContext bctx = bs.getICtx(rctx.currTx);
            bctx.setRemoved();
        } catch (Exception e) {
            rctx.sysExc = e;
            logger.log(BasicLevel.ERROR, "EJB exception thrown:", e);
        } catch (Error e) {
            rctx.sysExc = e;
            logger.log(BasicLevel.ERROR, "error thrown:", e);
        } finally {
            try {
                bf.postInvoke(rctx);
            } catch (Exception e) {
                logger.log(BasicLevel.ERROR, "exception on postInvoke: ", e);
            }
        }
        
    }
    
}

---