EntityBean.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: EntityBean.java,v 1.4 2004/12/01 13:35:34 durieuxp Exp $
 * --------------------------------------------------------------------------
 */

package org.objectweb.jonas.container;

import org.objectweb.jonas_ejb.container.EntityCounters;
import org.objectweb.jonas_ejb.container.JEntityFactory;
import org.objectweb.jonas_ejb.deployment.api.EntityDesc;

public class EntityBean extends EJB {

    // lock policy
    private static final int LOCK_CONTAINER_READ_UNCOMMITTED = EntityDesc.LOCK_CONTAINER_READ_UNCOMMITTED;
    private static final int LOCK_CONTAINER_SERIALIZED = EntityDesc.LOCK_CONTAINER_SERIALIZED;
    private static final int LOCK_CONTAINER_READ_COMMITTED = EntityDesc.LOCK_CONTAINER_READ_COMMITTED;
    private static final int LOCK_DATABASE = EntityDesc.LOCK_DATABASE;
    private static final int LOCK_READ_ONLY = EntityDesc.LOCK_READ_ONLY;

    private String persistency;

    public EntityBean(String objectName, JEntityFactory factoryToManage, String persistency) {
        super(objectName, factoryToManage);
        this.persistency = persistency;
    }

    public String getPersistency() {
        return persistency;
    }

    public int getPassivationTimeOut() {
        return ejbToManage.getContainer().getSwapTime();
    }

    public void setPassivationTimeOut(int timeOut) {
        ejbToManage.getContainer().setSwapTime(timeOut);
    }

    public int getInactivityTimeOut() {
        return ((JEntityFactory) ejbToManage).getInactivityTimeout();
    }

    public boolean getShared() {
        return ((JEntityFactory) ejbToManage).isShared();
    }

    public int getMinPoolSize() {
        return ((JEntityFactory) ejbToManage).getMinPoolSize();
    }

    public int getMaxCacheSize() {
        return ((JEntityFactory) ejbToManage).getMaxCacheSize();
    }

    public int getPoolSize() {
        return ((JEntityFactory) ejbToManage).getPoolSize();
    }

    public String getLockPolicy() {
        int lockPolicy = ((JEntityFactory) ejbToManage).lockPolicy();
        String sLockPolicy = null;
        switch (lockPolicy) {
            case LOCK_CONTAINER_READ_UNCOMMITTED:
                sLockPolicy = "container-read-uncommitted";
                break;
            case LOCK_CONTAINER_SERIALIZED:
                sLockPolicy = "container-serialized";
                break;
            case LOCK_CONTAINER_READ_COMMITTED:
                sLockPolicy = "container-read-committed";
                break;
            case LOCK_DATABASE:
                sLockPolicy = "database";
                break;
            case LOCK_READ_ONLY:
                sLockPolicy = "read-only";
                break;
        }
        return sLockPolicy;
    }

    public boolean getPrefetch() {
        return ((JEntityFactory) ejbToManage).isPrefetch();
    }
    public int getCacheSize() {
        return ((JEntityFactory) ejbToManage).getCacheSize();
    }

    public Integer[] getEntityCounters() {
        EntityCounters ec = ((JEntityFactory) ejbToManage).getEntityCounters();
        Integer[] result = new Integer[5];
        result[0] = new Integer(ec.inTx);
        result[1] = new Integer(ec.outTx);
        result[2] = new Integer(ec.idle);
        result[3] = new Integer(ec.passive);
        result[4] = new Integer(ec.removed);
        return result;
    }

    public void synchronize() {
        ((JEntityFactory) ejbToManage).sync();
    }

    public void reduceCache() {
        ((JEntityFactory) ejbToManage).reduceCache();
    }
}

---