LocalXAWrapper.java

/*
 * JOnAS: Java(TM) Open Application Server
 * Copyright (C) 1999 Bull S.A.
 * Contact: jonas-team@objectweb.org
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or any later version.
 *
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307
 * USA
 *
 * --------------------------------------------------------------------------
 * $Id: LocalXAWrapper.java,v 1.6 2004/10/29 23:33:37 ehardesty Exp $
 * --------------------------------------------------------------------------
 */


package org.objectweb.jonas.resource;

import javax.resource.ResourceException;
import javax.resource.spi.LocalTransaction;

import javax.transaction.xa.XAResource;
import javax.transaction.xa.XAException;
import javax.transaction.xa.Xid;

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

public final class LocalXAWrapper
    implements XAResource {

    private static Logger logger = null;

    protected boolean isInTransaction;

    protected LocalTransaction localTrans = null;

    LocalXAWrapper(LocalTransaction _localTrans, Logger _logger) {
        isInTransaction = false;
        localTrans = _localTrans;
        logger = _logger;
    }

    public void commit(Xid xid, boolean flag)
        throws XAException {
        logger.log(BasicLevel.DEBUG, "Xid =" + xid + "flag=" + flag);


        if (isInTransaction) {
            // Unbalance start/end. Probably a close is missing.
            // We decide to unset isInTransaction here to avoid a further error
            logger.log(BasicLevel.DEBUG, "XA START without XA END");
            isInTransaction = false;
        }

        try {
            localTrans.commit();
        } catch (ResourceException res) {
            throw new XAException(res.toString());
        }
    }

    public void end(Xid xid, int i)
        throws XAException {
        logger.log(BasicLevel.DEBUG, "Xid =" + xid + "i=" + i);
        if (!isInTransaction) {
            logger.log(BasicLevel.ERROR, "END without START");
            XAException ex = new XAException(XAException.XA_RBPROTO);
            throw(ex);
        }
        isInTransaction = false;

    }

    public void forget(Xid xid)
        throws XAException {
        logger.log(BasicLevel.DEBUG, "");
    }

    public int getTransactionTimeout()
        throws XAException {
        logger.log(BasicLevel.DEBUG, "");
        return -1;
    }

    public boolean isSameRM(XAResource xaresource)
        throws XAException {
        logger.log(BasicLevel.DEBUG, "");

        if (xaresource.equals(this)) {
            logger.log(BasicLevel.DEBUG, "isSameRM = true " + this);
            return true;
        }
        logger.log(BasicLevel.DEBUG, "isSameRM = false " + this);
        return false;
    }

    public int prepare(Xid xid)
        throws XAException {
        logger.log(BasicLevel.DEBUG, "");
        return XAResource.XA_OK;
    }

    public Xid[] recover(int i)
        throws XAException {
        logger.log(BasicLevel.DEBUG, "");
        return null;
    }

    public void rollback(Xid xid)
        throws XAException {
        logger.log(BasicLevel.DEBUG, "Xid =" + xid);

        if (isInTransaction) {
            // Unbalance start/end. Probably a close is missing.
            // We decide to unset isInTransaction here to avoid a further error, but
            // I'm not sure it's a good idea.
            logger.log(BasicLevel.DEBUG, "XA START without XA END");
            isInTransaction = false;
        }

        try {
            localTrans.rollback();
        } catch (ResourceException res) {
            throw new XAException("Rollback failed, " + res.getMessage());
        }
    }

    public boolean setTransactionTimeout(int i)
        throws XAException {
        logger.log(BasicLevel.DEBUG, "");
        return false;
    }

    public void start(Xid xid, int i)
        throws XAException {
        logger.log(BasicLevel.DEBUG, "Xid =" + xid + "i=" + i);
        try {
            if (i != XAResource.TMJOIN && i != XAResource.TMRESUME) {
                if (isInTransaction) {
                    throw new XAException("LocalXAWrapper.start:  Local transaction already started");
                }
                localTrans.begin();
                isInTransaction = true;
            }
        } catch (ResourceException res) {
            throw new XAException("LocalTransaction.begin failed, " + res.toString());
        }
        logger.log(BasicLevel.DEBUG, "OK");
    }
}

---