EJB.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: EJB.java,v 1.6 2004/12/07 15:35:25 danesa Exp $
 * --------------------------------------------------------------------------
 */

package org.objectweb.jonas.container;

import java.util.Enumeration;
import java.util.HashSet;
import java.util.Hashtable;
import java.util.Set;
import java.util.Vector;

import org.objectweb.jonas.dbm.DataBaseServiceImpl;
import org.objectweb.jonas.mail.MailServiceImpl;
import org.objectweb.jonas.management.j2eemanagement.J2EEManagedObject;
import org.objectweb.jonas.service.ServiceException;
import org.objectweb.jonas.service.ServiceManager;
import org.objectweb.jonas_ejb.container.JFactory;
import org.objectweb.jonas_ejb.deployment.api.BeanDesc;
import org.objectweb.jonas_ejb.deployment.api.EntityJdbcCmp1Desc;
import org.objectweb.jonas_ejb.deployment.api.EntityJdbcCmp2Desc;
import org.objectweb.jonas_lib.deployment.api.ResourceEnvRefDesc;
import org.objectweb.jonas_lib.deployment.api.ResourceRefDesc;

public class EJB extends J2EEManagedObject {
    protected JFactory ejbToManage = null;
    protected BeanDesc desc = null;
    protected String fileName = null;

    public EJB(String objectName, JFactory ejbToManage) {
        super(objectName);
        this.ejbToManage = ejbToManage;
        this.fileName = ejbToManage.getContainer().getFileName();
        this.desc = ejbToManage.getDeploymentDescriptor();
    }


    public String getName() {
        return desc.getEjbName();
    }

    public String getFileName() {
        return fileName;
    }

    public Hashtable getAllDataSourceName() {
        Hashtable result = new Hashtable();
        
        DataBaseServiceImpl bdmServ = null;
        String jndiName = null;
        Vector jndiNames = new Vector();
        String datasourceName = null;

        // find the resource refs
        ResourceRefDesc[] rrDesc = desc.getResourceRefDesc();
        for (int i = 0; i < rrDesc.length; i ++) {
            if (rrDesc[i].isJdbc()) {
                // get the DD provided JNDI name
                jndiName = rrDesc[i].getJndiName();
                jndiNames.add(jndiName);
            }
        }

        // if the EJB is an entity with CMP, we have to find jndi name in the jdbc_mapping
        // in case of CMP1 :
        EntityJdbcCmp1Desc jdbcCmp1Desc = null;
        try {
            jdbcCmp1Desc = (EntityJdbcCmp1Desc) desc;
            jndiName = jdbcCmp1Desc.getDatasourceJndiName();
            jndiNames.add(jndiName);
        } catch (Exception e) {
        }
        // in case of CMP2 :
        EntityJdbcCmp2Desc jdbcCmp2Desc = null;
        try {
            jdbcCmp2Desc = (EntityJdbcCmp2Desc) desc;
            jndiName = jdbcCmp2Desc.getDatasourceJndiName();
            jndiNames.add(jndiName);
        } catch (Exception e) {
        }

        if (!jndiNames.isEmpty()) {
            try {
                // Modified for use with the gcj compiler
                ServiceManager sm = ServiceManager.getInstance();
                bdmServ = (DataBaseServiceImpl) sm.getDataBaseService();
            } catch(Exception e) {
                // DataBase Service not available
                // Temporary solution
                return result;                  
            }
        }

        for (Enumeration e = jndiNames.elements() ; e.hasMoreElements() ;) {
            jndiName = (String)e.nextElement();
            datasourceName = bdmServ.getDatasourceName(jndiName);
            if (datasourceName != null)
                result.put(jndiName, datasourceName);
            else
                result.put(jndiName, "");
        }

        return result;
    }

 
    public Set getAllJMSConnectionFactoryName(){
        Set result= new HashSet();
        ResourceRefDesc[] rrDesc = desc.getResourceRefDesc();
        for (int i = 0; i < rrDesc.length; i ++) {
            if ("javax.jms.TopicConnectionFactory".equals(rrDesc[i].getTypeName())
                || "javax.jms.QueueConnectionFactory".equals(rrDesc[i].getTypeName())
                || "javax.jms.ConnectionFactory".equals(rrDesc[i].getTypeName())) {
                result.add(rrDesc[i].getJndiName()); 
            }
        }
        return result;
    }

    public Hashtable getAllMailFactorySName(){
        Hashtable result = new Hashtable();
        MailServiceImpl mailServ = null;
        try {
            // Modified for use with the gcj compiler
            ServiceManager sm = ServiceManager.getInstance();
            mailServ = (MailServiceImpl) sm.getMailService();
        } catch(Exception e) {
            // Mail Service not available, mailServ null
        }
        String jndiName = null; // name provided by the DD
        String factoryName = null; // resource name 

        ResourceRefDesc[] rrDesc = desc.getResourceRefDesc();
        for (int i = 0; i < rrDesc.length; i ++) {
            if ("javax.mail.Session".equals(rrDesc[i].getTypeName())) {
                // The Bean uses a javax.mail.Session resource

                // get the DD provided JNDI name
                jndiName = rrDesc[i].getJndiName();

                // try to get the mail service
                if (mailServ != null) {                         
                    // get the resource factory name (maybe null if no resource factory registered under the jndiName)
                    factoryName = mailServ.getFactoryName(jndiName);
                    if (factoryName != null)
                        result.put(jndiName, factoryName);
                    else
                        result.put(jndiName, "");
                } else {
                    // Mail Service not available
                    result.put(jndiName, "");
                }
            }
        }
        return result;
    }

    public Hashtable getAllMailFactoryMName() {
        Hashtable result = new Hashtable();
        MailServiceImpl mailServ = null; 
        try {
            // Modified for use with the gcj compiler
            ServiceManager sm = ServiceManager.getInstance();
            mailServ = (MailServiceImpl) sm.getMailService();
        } catch(Exception e) {
            // Mail Service not available, mailServ null
        }
        String jndiName = null;
        String factoryName = null;

        ResourceRefDesc[] rrDesc = desc.getResourceRefDesc();
        for (int i = 0; i < rrDesc.length; i ++) {
            if ("javax.mail.internet.MimePartDataSource".equals(rrDesc[i].getTypeName())) {
                // the Bean uses a javax.mail.internet.MimePartDataSource resource

                // get the DD provided JNDI name
                jndiName = rrDesc[i].getJndiName();

                if (mailServ != null) {
                    // get the resource factory name (maybe bull if no resource factory registered under the jndiName)
                    factoryName = mailServ.getFactoryName(jndiName);
                    if (factoryName != null) 
                        result.put(jndiName, factoryName);
                    else
                        result.put(jndiName, "");
                } else {
                    // Mail Service not available
                    result.put(jndiName, "");
                }
            }
        }
        return result;
    }

    public Set getAllJMSDestinationName(){
        Set result= new HashSet();
        ResourceEnvRefDesc[] rrDesc = desc.getResourceEnvRefDesc();
        for (int i = 0; i < rrDesc.length; i ++) {
            if ((rrDesc[i].getType() == javax.jms.Topic.class )
                ||(rrDesc[i].getType() == javax.jms.Queue.class )) { 
                result.add(rrDesc[i].getJndiName()); 
            }
        }
        return result;
    }

    public Set getAllURLs() {
        Set result= new HashSet();
        ResourceRefDesc[] rrDesc = desc.getResourceRefDesc();
        for (int i = 0; i < rrDesc.length; i ++) {
            if ("java.net.URL".equals(rrDesc[i].getTypeName())) {
                result.add(rrDesc[i].getJndiName()); 
            }
        }
        return result;        
    }

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

    public String getEjbClass(){
        return desc.getEjbClass().getName();
    }

    public String getDisplayName() {
        return desc.getDisplayName() != null ? desc.getDisplayName() : desc.getEjbName();
    }

    public String getJndiName() {
        return desc.getJndiName();
    }

    public String getHomeClass() {
        if (desc.getHomeClass() != null) {
            return desc.getHomeClass().getName();
        } else {
            return null;
        }
    }

    public String getRemoteClass() {
        if (desc.getRemoteClass() != null) {
            return desc.getRemoteClass().getName();
        } else {
            return null;
        }
    }

    public String getLocalHomeClass() {
        if (desc.getLocalHomeClass() != null) {
            return desc.getLocalHomeClass().getName();
        } else {
            return null;
        }
    }

    public String getLocalClass() {
        if (desc.getLocalClass() != null) {
            return desc.getLocalClass().getName();
        } else {
            return null;
        }
    }

}

---