JTAResource.java

package org.objectweb.jonas.jtm;

// JOnAS imports
import org.objectweb.jonas.management.j2eemanagement.J2EEResource;
import org.objectweb.jonas.management.ReconfiguredProp;

import javax.transaction.xa.Xid;

import java.util.ArrayList;

public class JTAResource extends J2EEResource {

    public static final String SERVICE_NAME = "jtm";

    // Transaction Service configuration properties
    static final String TIMEOUT = "jonas.service.jtm.timeout";

    private long sequenceNumber = 0;

    private Integer timeOut;

    private Integer portNumber;

    private String hostName;

    private Boolean localJtm;

    private TransactionServiceImpl jtm;

    public JTAResource(String objectName, TransactionServiceImpl jtm, Integer timeOut, Boolean localJtm,
            Integer portNumber, String hostName) {
        super(objectName);
        this.jtm = jtm;
        this.timeOut = timeOut;
        this.localJtm = localJtm;
        this.portNumber = portNumber;
        this.hostName = hostName;
    }

    public Integer getTimeOut() {
        return timeOut;
    }

    public void setTimeOut(Integer timeOut) {
        this.timeOut = timeOut;
        jtm.setTimeout(timeOut.intValue());
        // Send a notification containing the new value of this property to the
        // listner MBean
        sendReconfigNotification(++sequenceNumber, SERVICE_NAME, new ReconfiguredProp(TIMEOUT, timeOut.toString()));
    }

    public Boolean isLocalJtm() {
        return localJtm;
    }

    public Integer getPortNumber() {
        return portNumber;
    }

    public String getHostName() {
        return hostName;
    }

    public void saveConfig() {
        sendSaveNotification(++sequenceNumber, SERVICE_NAME);
    }

    public Integer getTotalBegunTransactions() {
        return new Integer(jtm.getTotalBegunTransactions());
    }
    public Integer getTotalCommittedTransactions() {
        return new Integer(jtm.getTotalCommittedTransactions());
    }
    public Integer getTotalCurrentTransactions() {
        return new Integer(jtm.getTotalCurrentTransactions());
    }
    public Integer getTotalExpiredTransactions() {
        return new Integer(jtm.getTotalExpiredTransactions());
    }
    public Integer getTotalRolledbackTransactions() {
        return new Integer(jtm.getTotalRolledbackTransactions());
    }
    public void resetAllCounters() {
        jtm.resetAllTxTotalCounters();
    }

    public Xid[] getAllActiveXids() {
        return jtm.getAllActiveXids();
    }

    public String [] getAllActiveTx() {
        String [] mysArray;

        mysArray = jtm.getAllActiveTx();
        return mysArray;
    }
}

---