Attachment #173104 for bug #316513

This Bugzilla instance is deprecated, and most Eclipse projects now use GitHub or Eclipse GitLab. Please see the deprecation plan for details.

View | Details | Raw Unified | Return to bug 316513 | Differences between

and this patch

Collapse All | Expand All

Lines 40-46 Link Here

(-)foundation/org.eclipse.persistence.core/src/org/eclipse/persistence/platform/server/CustomServerPlatform.java (-1 lines)
40	*/	40	*/
41	public CustomServerPlatform(DatabaseSession newDatabaseSession) {	41	public CustomServerPlatform(DatabaseSession newDatabaseSession) {
42	super(newDatabaseSession);	42	super(newDatabaseSession);
43	this.disableRuntimeServices();
44	}	43	}
45		44
46	/**	45	/**

Lines 9-24 Link Here

(-)foundation/org.eclipse.persistence.core/src/org/eclipse/persistence/platform/server/jboss/JBossPlatform.java (-5 / +35 lines)
9	*	9	*
10	* Contributors:	10	* Contributors:
11	* Oracle - initial API and implementation from Oracle TopLink	11	* Oracle - initial API and implementation from Oracle TopLink
		12	* 06/22/2010-2.2 Michael O'Brien
		13	* - 316511: Add JBoss specific JMX MBean attributes and functions
		14	* see <link>http://wiki.eclipse.org/EclipseLink/DesignDocs/316513</link>
12	******************************************************************************/	15	******************************************************************************/
13	package org.eclipse.persistence.platform.server.jboss;	16	package org.eclipse.persistence.platform.server.jboss;
14		17
15	import javax.persistence.spi.PersistenceUnitInfo;	18	import javax.persistence.spi.PersistenceUnitInfo;
16		19
		20	import org.eclipse.persistence.internal.helper.JPAClassLoaderHolder;
		21	import org.eclipse.persistence.logging.AbstractSessionLog;
		22	import org.eclipse.persistence.platform.server.JMXServerPlatformBase;
		23	import org.eclipse.persistence.services.jboss.MBeanJBossRuntimeServices;
		24	import org.eclipse.persistence.services.mbean.MBeanRuntimeServicesMBean;
17	import org.eclipse.persistence.sessions.DatabaseSession;	25	import org.eclipse.persistence.sessions.DatabaseSession;
18	import org.eclipse.persistence.transaction.jboss.JBossTransactionController;	26	import org.eclipse.persistence.transaction.jboss.JBossTransactionController;
19	import org.eclipse.persistence.internal.helper.JPAClassLoaderHolder;
20	import org.eclipse.persistence.logging.AbstractSessionLog;
21	import org.eclipse.persistence.platform.server.ServerPlatformBase;
22		27
23	/**	28	/**
24	* PUBLIC:	29	* PUBLIC:
Lines 30-36 Link Here
30	* getExternalTransactionControllerClass(): to use an JBoss-specific controller class	35	* getExternalTransactionControllerClass(): to use an JBoss-specific controller class
31	*	36	*
32	*/	37	*/
33	public class JBossPlatform extends ServerPlatformBase {	38	public class JBossPlatform extends JMXServerPlatformBase {
34		39
35	/**	40	/**
36	* INTERNAL:	41	* INTERNAL:
Lines 38-45 Link Here
38	*/	43	*/
39	public JBossPlatform(DatabaseSession newDatabaseSession) {	44	public JBossPlatform(DatabaseSession newDatabaseSession) {
40	super(newDatabaseSession);	45	super(newDatabaseSession);
		46	this.enableRuntimeServices();
41	}	47	}
42		48
		49	public boolean isJMXEnabled() {
		50	return true;
		51	}
		52
43	/**	53	/**
44	* INTERNAL: getExternalTransactionControllerClass(): Answer the class of external transaction controller to use	54	* INTERNAL: getExternalTransactionControllerClass(): Answer the class of external transaction controller to use
45	* for JBoss. This is read-only.	55	* for JBoss. This is read-only.
Lines 75-79 Link Here
75	AbstractSessionLog.getLog().log(AbstractSessionLog.WARNING, "persistence_unit_processor_jboss_temp_classloader_bypassed",//	85	AbstractSessionLog.getLog().log(AbstractSessionLog.WARNING, "persistence_unit_processor_jboss_temp_classloader_bypassed",//
76	puInfo.getPersistenceUnitName(), realClassLoader);	86	puInfo.getPersistenceUnitName(), realClassLoader);
77	return new JPAClassLoaderHolder(realClassLoader, false);	87	return new JPAClassLoaderHolder(realClassLoader, false);
78	}	88	}
		89
		90	/**
		91	* INTERNAL:
		92	* serverSpecificRegisterMBean(): Server specific implementation of the
		93	* creation and deployment of the JMX MBean to provide runtime services for my
		94	* databaseSession.
		95	*
		96	* @return void
		97	* @see #isRuntimeServicesEnabled()
		98	* @see #disableRuntimeServices()
		99	* @see #registerMBean()
		100	*/
		101	public void serverSpecificRegisterMBean() {
		102	MBeanRuntimeServicesMBean runtimeBean = null;
		103	// No check for an existing cached MBean - we will replace it if it exists
		104	if(shouldRegisterRuntimeBean) {
		105	runtimeBean = new MBeanJBossRuntimeServices(getDatabaseSession());
		106	}
		107	genericRegisterMBean(runtimeBean);
		108	}
79	}	109	}




package org.eclipse.persistence.platform.server;

import javax.management.InstanceAlreadyExistsException;
import javax.management.InstanceNotFoundException;
import javax.management.MBeanRegistrationException;
import javax.management.MBeanServer;
import javax.management.MBeanServerFactory;
import javax.management.MalformedObjectNameException;
import javax.management.ObjectInstance;
import javax.management.ObjectName;

import org.eclipse.persistence.logging.AbstractSessionLog;
import org.eclipse.persistence.logging.SessionLog;
import org.eclipse.persistence.services.mbean.MBeanDevelopmentServices;
import org.eclipse.persistence.services.mbean.MBeanRuntimeServicesMBean;
import org.eclipse.persistence.sessions.DatabaseSession;

public abstract class JMXServerPlatformBase extends ServerPlatformBase {// implements JMXEnabledPlatform {

    /** Cache the JBoss MBeanServer for performance */
    private MBeanServer mBeanServer = null;
    
    /** cache the RuntimeServices MBean */
    private MBeanRuntimeServicesMBean runtimeServicesMBean = null;    

    /** moduleName determination is available during MBean registration only */
    private String moduleName = null;

    /** applicationName determination is available during MBean registration only */
    private String applicationName = null;
    
    /**
     * INTERNAL:
     * Default Constructor: Initialize so that runtime services and JTA are enabled. Set the DatabaseSession that I
     * will be helping.
     */
    public JMXServerPlatformBase(DatabaseSession newDatabaseSession) {
        super(newDatabaseSession);
        /**
         * INTERNAL:
         * Answer "unknown" as a default for platforms that do not implement getModuleName()
         */
        applicationName = DEFAULT_SERVER_NAME_AND_VERSION;
        moduleName = DEFAULT_SERVER_NAME_AND_VERSION;        
    }
    
    public MBeanServer getMBeanServer() {
        // lazy initialize the MBeanServer reference
        if(null == mBeanServer) {
            try {
                mBeanServer = (MBeanServer) MBeanServerFactory.findMBeanServer(null).get(0);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        return mBeanServer;
    } 
    
    /**
     * INTERNAL: 
     * serverSpecificRegisterMBean(): Server specific implementation of the
     * creation and deployment of the JMX MBean to provide runtime services for my
     * databaseSession.
     *
     * @return void
     * @see #isRuntimeServicesEnabled()
     * @see #disableRuntimeServices()
     * @see #registerMBean()
     */
    public void genericRegisterMBean(MBeanRuntimeServicesMBean servicesMBean) {
        // get and cache module and application name during registration
        //initializeApplicationNameAndModuleName();
        MBeanServer mBeanServerRuntime = getMBeanServer();      
        ObjectName name = null;      
        String sessionName = getMBeanSessionName();
        if (null != sessionName && (shouldRegisterDevelopmentBean || shouldRegisterRuntimeBean)) {
            try {                    
                    // Attempt to register new mBean with the server
                if (null != mBeanServerRuntime && shouldRegisterDevelopmentBean) {
                    try {
                        name = new ObjectName(JMX_REGISTRATION_PREFIX + "Development-" + sessionName + ",Type=Configuration");
                    } catch (MalformedObjectNameException mne) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", mne);
                    } catch (Exception exception) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", exception);
                    }

                    MBeanDevelopmentServices developmentMBean = new MBeanDevelopmentServices(getDatabaseSession());
                    ObjectInstance info = null;
                    try {
                        info = mBeanServerRuntime.registerMBean(developmentMBean, name);
                    } catch(InstanceAlreadyExistsException iaee) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", iaee);
                    } catch (MBeanRegistrationException registrationProblem) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", registrationProblem);
                    } catch (Exception e) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", e);
                    }
                    AbstractSessionLog.getLog().log(SessionLog.FINEST, "registered_mbean", info);
                }

                if (null != mBeanServerRuntime && shouldRegisterRuntimeBean) {
                    try {
                        name = new ObjectName(JMX_REGISTRATION_PREFIX + "Session(" + sessionName + ")");                        
                    } catch (MalformedObjectNameException mne) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", mne);
                    } catch (Exception exception) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", exception);
                    }
                    
                    ObjectInstance runtimeInstance = null;
                    try {
                        runtimeInstance = mBeanServerRuntime.registerMBean(servicesMBean, name);
                        setRuntimeServicesMBean(servicesMBean);
                    } catch(InstanceAlreadyExistsException iaee) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", iaee);
                    } catch (MBeanRegistrationException registrationProblem) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", registrationProblem);
                    } catch (Exception e) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", e);
                    }
                    AbstractSessionLog.getLog().log(SessionLog.FINEST, "registered_mbean", runtimeInstance);          
                }
            } catch (Exception exception) {
                AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", exception);
            }
        }
    }
    
    /**
     * INTERNAL: 
     * serverSpecificUnregisterMBean(): Server specific implementation of the
     * de-registration of the JMX MBean from its server during session logout.
     *
     * @return void
     * @see #isRuntimeServicesEnabled()
     * @see #disableRuntimeServices()
     */
    public void serverSpecificUnregisterMBean() {
        MBeanServer mBeanServerRuntime = getMBeanServer();      
        ObjectName name = null;      
        String sessionName = getMBeanSessionName();
        if (null != sessionName && (shouldRegisterDevelopmentBean || shouldRegisterRuntimeBean)) {
            try {
                
                // Attempt to register new mBean with the server
                if (shouldRegisterDevelopmentBean) {
                    try {
                        name = new ObjectName(JMX_REGISTRATION_PREFIX + "Development_" + sessionName + ",Type=Configuration");
                    } catch (MalformedObjectNameException mne) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_unregistering_mbean", mne);
                    } catch (Exception exception) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_unregistering_mbean", exception);
                    }

                    AbstractSessionLog.getLog().log(SessionLog.FINEST, "unregistering_mbean", name);
                    try {
                        mBeanServerRuntime.unregisterMBean(name);
                    } catch(InstanceNotFoundException inf) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_unregistering_mbean", inf);
                    } catch (MBeanRegistrationException mbre) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_unregistering_mbean", mbre);                        
                    }                                        
                }

                if (shouldRegisterRuntimeBean) {
                    try {                        
                        name = new ObjectName(JMX_REGISTRATION_PREFIX + "Session(" + sessionName + ")");                        
                    } catch (MalformedObjectNameException mne) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_unregistering_mbean", mne);
                    } catch (Exception exception) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_unregistering_mbean", exception);
                    }

                    AbstractSessionLog.getLog().log(SessionLog.FINEST, "unregistering_mbean", name);
                    try {
                        mBeanServerRuntime.unregisterMBean(name);
                    } catch(InstanceNotFoundException inf) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_unregistering_mbean", inf);
                    } catch (MBeanRegistrationException registrationProblem) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_unregistering_mbean", registrationProblem);
                    }                              
                }
            } catch (Exception exception) {
                AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_unregistering_mbean", exception);
            } finally {
                // de reference the mbean
                this.setRuntimeServicesMBean(null);
            }
        }
    }    
    
    /**
     * Remove JMX reserved characters from the session name
     * @param aSession
     * @return
     */
    protected String getMBeanSessionName() {
        // Check for a valid session - should never occur though        
        if(null != getDatabaseSession() && null != getDatabaseSession().getName()) {
            // remove any JMX reserved characters when the session name is file:/drive:/directory
            return getDatabaseSession().getName().replaceAll("[=,:]", "_");
        } else {
            AbstractSessionLog.getLog().log(SessionLog.WARNING, "session_key_for_mbean_name_is_null");
            return null;
        }
    }

    
    protected MBeanRuntimeServicesMBean getRuntimeServicesMBean() {
        return runtimeServicesMBean;
    }

    protected void setRuntimeServicesMBean(
            MBeanRuntimeServicesMBean runtimeServicesMBean) {
        this.runtimeServicesMBean = runtimeServicesMBean;
    }

    /**
     * INTERNAL: 
     * getModuleName(): Answer the name of the context-root of the application that this session is associated with.
     * Answer "unknown" if there is no module name available.
     * Default behavior is to return "unknown" - we override this behavior here for JBoss.
     * 
     * There are 4 levels of implementation.
     * 1) use the property override jboss.moduleName, or
     * 2) perform a reflective jboss.work.executeThreadRuntime.getModuleName() call, or
     * 3) extract the moduleName:persistence_unit from the jboss classloader string representation, or
     * 3) defer to superclass - usually return "unknown"
     *
     * @return String moduleName
     */
    @Override
    public String getModuleName() {        
        return this.moduleName;
    }
    
    protected void setModuleName(String aName) {
        moduleName = aName;
    }
    
    /**
     * INTERNAL: 
     * getApplicationName(): Answer the name of the module (EAR name) that this session is associated with.
     * Answer "unknown" if there is no application name available.
     * Default behavior is to return "unknown" - we override this behavior here for JBoss.
     * 
     * There are 4 levels of implementation.
     * 1) use the property override weblogic.applicationName, or
     * 2) perform a reflective weblogic.work.executeThreadRuntime.getApplicationName() call, or
     * 3) extract the moduleName:persistence_unit from the weblogic classloader string representation, or
     * 3) defer to superclass - usually return "unknown"
     *
     * @return String applicationName
     */
    public String getApplicationName() {
        return this.applicationName;
    }
    
    
    public void setApplicationName(String aName) {
        applicationName = aName;
    }

}

Lines 37-43 Link Here

(-)foundation/org.eclipse.persistence.core/src/org/eclipse/persistence/platform/server/NoServerPlatform.java (-1 lines)
37	*/	37	*/
38	public NoServerPlatform(DatabaseSession newDatabaseSession) {	38	public NoServerPlatform(DatabaseSession newDatabaseSession) {
39	super(newDatabaseSession);	39	super(newDatabaseSession);
40	this.disableRuntimeServices();
41	this.disableJTA();	40	this.disableJTA();
42	}	41	}
43		42

Lines 122-127 Link Here

(-)foundation/org.eclipse.persistence.core/src/org/eclipse/persistence/platform/server/ServerPlatform.java (-1 / +3 lines)
122	*/	122	*/
123	public abstract boolean isJTAEnabled();	123	public abstract boolean isJTAEnabled();
124		124
		125	public abstract boolean isJMXEnabled();
		126
125	/**	127	/**
126	* INTERNAL: disableJTA(): Configure the receiver such that my external transaction controller class will	128	* INTERNAL: disableJTA(): Configure the receiver such that my external transaction controller class will
127	* be ignored, and will NOT be used to populate DatabaseSession's external transaction controller class	129	* be ignored, and will NOT be used to populate DatabaseSession's external transaction controller class
Lines 172-178 Link Here
172	* @see #registerMBean()	174	* @see #registerMBean()
173	*/	175	*/
174	public abstract void unregisterMBean();	176	public abstract void unregisterMBean();
175		177
176	/**	178	/**
177	* INTERNAL: This method is used to unwrap the oracle connection wrapped by	179	* INTERNAL: This method is used to unwrap the oracle connection wrapped by
178	* the application server. TopLink needs this unwrapped connection for certain	180	* the application server. TopLink needs this unwrapped connection for certain

Lines 9-14 Link Here

(-)foundation/org.eclipse.persistence.core/src/org/eclipse/persistence/platform/server/ServerPlatformBase.java (-79 / +126 lines)
9	*	9	*
10	* Contributors:	10	* Contributors:
11	* Oracle - initial API and implementation from Oracle TopLink	11	* Oracle - initial API and implementation from Oracle TopLink
		12	* 06/22/2010-2.2 Michael O'Brien
		13	* - 316509: Move JMX MBean generic registration code up from specific platforms
		14	* see <link>http://wiki.eclipse.org/EclipseLink/DesignDocs/316513</link>
12	******************************************************************************/	15	******************************************************************************/
13	package org.eclipse.persistence.platform.server;	16	package org.eclipse.persistence.platform.server;
14		17
Lines 44-50 Link Here
44	* <li> Whether or not to enable runtime services	47	* <li> Whether or not to enable runtime services
45	* <li> How to launch container Threads	48	* <li> How to launch container Threads
46	* </ul><p>	49	* </ul><p>
47	* Subclasses already exist to provide configurations for Oc4J, WebLogic, JBoss, and WebSphere.	50	* Subclasses already exist to provide configurations for Oc4J, WebLogic, JBoss, NetWeaver, GlassFish and WebSphere.
48	* <p>	51	* <p>
49	* If the user wants a different external transaction controller class or	52	* If the user wants a different external transaction controller class or
50	* to provide some different behavior than the provided ServerPlatform(s), we recommend	53	* to provide some different behavior than the provided ServerPlatform(s), we recommend
Lines 61-85 Link Here
61	*/	64	*/
62	public abstract class ServerPlatformBase implements ServerPlatform {	65	public abstract class ServerPlatformBase implements ServerPlatform {
63		66
		67	// Secondary override properties can be set to disable MBean registration
		68	/** This System property "eclipselink.register.dev.mbean" when set to true will enable registration/unregistration of the DevelopmentServices MBean */
		69	public static final String JMX_REGISTER_DEV_MBEAN_PROPERTY = "eclipselink.register.dev.mbean";
		70	/** This System property "eclipselink.register.run.mbean" when set to true will enable registration/unregistration of the RuntimeServices MBean */
		71	public static final String JMX_REGISTER_RUN_MBEAN_PROPERTY = "eclipselink.register.run.mbean";
		72	/** This is the prefix for all MBeans that are registered with their specific session name appended */
		73	public static final String JMX_REGISTRATION_PREFIX = "TopLink:Name=";
64	/**	74	/**
65	* externalTransactionControllerClass: This is a user-specifiable class defining the class	75	* INTERNAL:
66	* of external transaction controller to be set into the DatabaseSession	76	* Answer "unknown" as a default for platforms that do not implement getModuleName()
67	*/	77	*/
68	protected Class externalTransactionControllerClass;	78	public static final String DEFAULT_SERVER_NAME_AND_VERSION = ToStringLocalization.buildMessage("unknown");
69		79
		80
70	/**	81	/**
71	* INTERNAL:	82	* INTERNAL:
72	* isRuntimeServicesEnabled: Determines if the JMX Runtime Services will be deployed at runtime	83	* isRuntimeServicesEnabled: Determines if the JMX Runtime Services will be deployed at runtime
73	*/	84	*/
74	private boolean isRuntimeServicesEnabled;	85	private boolean isRuntimeServicesEnabled;
75		86
		87	// Any value such as true will turn on the MBean
		88	protected boolean shouldRegisterDevelopmentBean = false;//System.getProperty(JMX_REGISTER_DEV_MBEAN_PROPERTY) != null;
		89	protected boolean shouldRegisterRuntimeBean = true;//System.getProperty(JMX_REGISTER_RUN_MBEAN_PROPERTY) != null;
		90
		91
76	/**	92	/**
		93	* externalTransactionControllerClass: This is a user-specifiable class defining the class
		94	* of external transaction controller to be set into the DatabaseSession
		95	*/
		96	protected Class externalTransactionControllerClass;
		97
		98
		99	/**
77	* INTERNAL:	100	* INTERNAL:
78	* isJTAEnabled: Determines if the external transaction controller will be populated into the DatabaseSession	101	* isJTAEnabled: Determines if the external transaction controller will be populated into the DatabaseSession
79	* at runtime	102	* at runtime
80	*/	103	*/
81	private boolean isJTAEnabled;	104	private boolean isJTAEnabled;
82		105
		106
83	/**	107	/**
84	* INTERNAL:	108	* INTERNAL:
85	* isCMP: true if the container created the server platform, because we're configured	109	* isCMP: true if the container created the server platform, because we're configured
Lines 101-120 Link Here
101		125
102	/**	126	/**
103	* INTERNAL:	127	* INTERNAL:
104	* Answer "unknown" as a default for platforms that do not implement getModuleName()
105	*/
106	public static final String DEFAULT_SERVER_NAME_AND_VERSION = ToStringLocalization.buildMessage("unknown");
107
108	/**
109	* INTERNAL:
110	* Default Constructor: Initialize so that runtime services and JTA are enabled. Set the DatabaseSession that I	128	* Default Constructor: Initialize so that runtime services and JTA are enabled. Set the DatabaseSession that I
111	* will be helping.	129	* will be helping.
112	*/	130	*/
113	public ServerPlatformBase(DatabaseSession newDatabaseSession) {	131	public ServerPlatformBase(DatabaseSession newDatabaseSession) {
114	this.isRuntimeServicesEnabled = true;
115	this.isJTAEnabled = true;	132	this.isJTAEnabled = true;
		133	// Default JMX support to true for all sub-platforms but disable parent platform where applicable
		134	this.isRuntimeServicesEnabled = false;
116	this.databaseSession = newDatabaseSession;	135	this.databaseSession = newDatabaseSession;
117	this.setIsCMP(false);	136	this.setIsCMP(false);
		137	//
		138	String shouldRegisterRuntimeBeanProperty = System.getProperty(JMX_REGISTER_RUN_MBEAN_PROPERTY);
		139	if(null != shouldRegisterRuntimeBeanProperty && shouldRegisterRuntimeBeanProperty.toLowerCase().indexOf("true") > -1) {
		140	shouldRegisterRuntimeBean = true;
		141	}
		142	String shouldRegisterDevelopmentBeanProperty = System.getProperty(JMX_REGISTER_DEV_MBEAN_PROPERTY);
		143	if(null != shouldRegisterDevelopmentBeanProperty && shouldRegisterDevelopmentBeanProperty.toLowerCase().indexOf("true") > -1) {
		144	shouldRegisterDevelopmentBean = true;
		145	}
118	}	146	}
119		147
120	/**	148	/**
Lines 281-304 Link Here
281	return this.isJTAEnabled;	309	return this.isJTAEnabled;
282	}	310	}
283		311
284	/**	312	public boolean isJMXEnabled() {
285	* INTERNAL: disableJTA(): Configure the receiver such that my external transaction controller class will	313	return false;
286	* be ignored, and will NOT be used to populate DatabaseSession's external transaction controller class
287	* at runtime.
288	*
289	* TopLink will NOT be configured to register for callbacks for beforeCompletion and afterCompletion.
290	*
291	* @return void
292	* @see #getExternalTransactionControllerClass()
293	* @see #isJTAEnabled()
294	*/
295	public void disableJTA() {
296	this.ensureNotLoggedIn();
297	this.isJTAEnabled = false;
298	}	314	}
299		315
300	/**	316	/**
301	* INTERNAL: isRuntimeServicesEnabled(): Answer true if the JMX/MBean providing runtime services for	317	* INTERNAL:
		318	* isRuntimeServicesEnabled(): Answer true if the JMX/MBean providing runtime services for
302	* the receiver's DatabaseSession will be deployed at runtime.	319	* the receiver's DatabaseSession will be deployed at runtime.
303	*	320	*
304	* @return boolean isRuntimeServicesEnabled	321	* @return boolean isRuntimeServicesEnabled
Lines 307-313 Link Here
307	public boolean isRuntimeServicesEnabled() {	324	public boolean isRuntimeServicesEnabled() {
308	return this.isRuntimeServicesEnabled;	325	return this.isRuntimeServicesEnabled;
309	}	326	}
310		327
311	/**	328	/**
312	* INTERNAL: disableRuntimeServices(): Configure the receiver such that no JMX/MBean will be registered	329	* INTERNAL: disableRuntimeServices(): Configure the receiver such that no JMX/MBean will be registered
313	* to provide runtime services for my DatabaseSession at runtime.	330	* to provide runtime services for my DatabaseSession at runtime.
Lines 321-375 Link Here
321	}	338	}
322		339
323	/**	340	/**
324	* INTERNAL: registerMBean(): Create and deploy the JMX MBean to provide runtime services for my	341	* INTERNAL:
325	* databaseSession.	342	* enableRuntimeServices(): Configure the receiver such that JMX/MBeans will be registered
		343	* to provide runtime services for my DatabaseSession at runtime.
326	*	344	*
327	* Default is to do nothing.
328	*
329	* @return void	345	* @return void
330	* @see #isRuntimeServicesEnabled()	346	* @see #isRuntimeServicesEnabled()
331	* @see #disableRuntimeServices()	347	* @since EclipseLink 2.2.0
332	* @see #unregisterMBean()
333	*/	348	*/
334	public void registerMBean() {	349	public void enableRuntimeServices() {
335	if (!this.isRuntimeServicesEnabled()) {	350	this.ensureNotLoggedIn();
336	return;	351	this.isRuntimeServicesEnabled = true;
337	}
338	this.serverSpecificRegisterMBean();
339	}	352	}
340		353
		354
341	/**	355	/**
342	* INTERNAL: serverSpecificRegisterMBean(): Server specific implementation of the	356	* INTERNAL: disableJTA(): Configure the receiver such that my external transaction controller class will
343	* creation and deployment of the JMX MBean to provide runtime services for my	357	* be ignored, and will NOT be used to populate DatabaseSession's external transaction controller class
344	* databaseSession.	358	* at runtime.
		359	*
		360	* TopLink will NOT be configured to register for callbacks for beforeCompletion and afterCompletion.
345	*	361	*
346	* Default is to do nothing. This should be subclassed if required.
347	*
348	* @return void	362	* @return void
349	* @see #isRuntimeServicesEnabled()	363	* @see #getExternalTransactionControllerClass()
350	* @see #disableRuntimeServices()	364	* @see #isJTAEnabled()
351	* @see #registerMBean()
352	*/	365	*/
353	public void serverSpecificRegisterMBean() {	366	public void disableJTA() {
		367	this.ensureNotLoggedIn();
		368	this.isJTAEnabled = false;
354	}	369	}
355		370
356	/**	371	/**
357	* INTERNAL: unregisterMBean(): Unregister the JMX MBean that was providing runtime services for my
358	* databaseSession.
359	*
360	* @return void
361	* @see #isRuntimeServicesEnabled()
362	* @see #disableRuntimeServices()
363	* @see #registerMBean()
364	*/
365	public void unregisterMBean() {
366	if (!this.isRuntimeServicesEnabled()) {
367	return;
368	}
369	this.serverSpecificUnregisterMBean();
370	}
371
372	/**
373	* INTERNAL: This method is used to unwrap the connection wrapped by	372	* INTERNAL: This method is used to unwrap the connection wrapped by
374	* the application server. TopLink needs this unwrapped connection for certain	373	* the application server. TopLink needs this unwrapped connection for certain
375	* database vendor specific support. (i.e. TIMESTAMPTZ,NCHAR,XMLTYPE)	374	* database vendor specific support. (i.e. TIMESTAMPTZ,NCHAR,XMLTYPE)
Lines 386-404 Link Here
386	}	385	}
387		386
388	/**	387	/**
389	* INTERNAL: serverSpecificUnregisterMBean(): Server specific implementation of the
390	* unregistration of the JMX MBean from its server.
391	*
392	* Default is to do nothing. This should be subclassed if required.
393	*
394	* @return void
395	* @see #isRuntimeServicesEnabled()
396	* @see #disableRuntimeServices()
397	*/
398	public void serverSpecificUnregisterMBean() {
399	}
400
401	/**
402	* INTERNAL: launchContainerRunnable(Runnable runnable): Use the container library to	388	* INTERNAL: launchContainerRunnable(Runnable runnable): Use the container library to
403	* start the provided Runnable.	389	* start the provided Runnable.
404	*	390	*
Lines 487-490 Link Here
487	*/	473	*/
488	public void clearStatementCache(java.sql.Connection connection) {	474	public void clearStatementCache(java.sql.Connection connection) {
489	}	475	}
		476
		477	/**
		478	* INTERNAL: registerMBean(): Create and deploy the JMX MBean to provide runtime services for my
		479	* databaseSession.
		480	*
		481	* Default is to do nothing.
		482	*
		483	* @return void
		484	* @see #isRuntimeServicesEnabled()
		485	* @see #disableRuntimeServices()
		486	* @see #unregisterMBean()
		487	*/
		488	public void registerMBean() {
		489	if (!this.isRuntimeServicesEnabled()) {
		490	return;
		491	}
		492	this.serverSpecificRegisterMBean();
		493	}
		494
		495	/**
		496	* INTERNAL: unregisterMBean(): Unregister the JMX MBean that was providing runtime services for my
		497	* databaseSession.
		498	*
		499	* @return void
		500	* @see #isRuntimeServicesEnabled()
		501	* @see #disableRuntimeServices()
		502	* @see #registerMBean()
		503	*/
		504	public void unregisterMBean() {
		505	if (!this.isRuntimeServicesEnabled()) {
		506	return;
		507	}
		508	this.serverSpecificUnregisterMBean();
		509	}
		510
		511
		512	/**
		513	* INTERNAL: serverSpecificUnregisterMBean(): Server specific implementation of the
		514	* unregistration of the JMX MBean from its server.
		515	*
		516	* Default is to do nothing. This should be subclassed if required.
		517	*
		518	* @return void
		519	* @see #isRuntimeServicesEnabled()
		520	* @see #disableRuntimeServices()
		521	*/
		522	public void serverSpecificUnregisterMBean() { }
		523
		524	/**
		525	* INTERNAL: serverSpecificRegisterMBean(): Server specific implementation of the
		526	* creation and deployment of the JMX MBean to provide runtime services for my
		527	* databaseSession.
		528	*
		529	* Default is to do nothing. This should be subclassed if required.
		530	*
		531	* @return void
		532	* @see #isRuntimeServicesEnabled()
		533	* @see #disableRuntimeServices()
		534	* @see #registerMBean()
		535	*/
		536	public void serverSpecificRegisterMBean() { }
490	}	537	}




 ******************************************************************************/  
package org.eclipse.persistence.platform.server.was;

import java.lang.reflect.Method;
import java.security.AccessController;

import javax.management.InstanceAlreadyExistsException;
import javax.management.InstanceNotFoundException;
import javax.management.MBeanRegistrationException;
import javax.management.MBeanServer;
import javax.management.MBeanServerFactory;
import javax.management.MalformedObjectNameException;
import javax.management.ObjectInstance;
import javax.management.ObjectName;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.persistence.spi.PersistenceUnitInfo;

import org.eclipse.persistence.internal.helper.JPAClassLoaderHolder;
import org.eclipse.persistence.internal.security.PrivilegedAccessHelper;
import org.eclipse.persistence.internal.security.PrivilegedMethodInvoker;
import org.eclipse.persistence.logging.AbstractSessionLog;
import org.eclipse.persistence.logging.SessionLog;
import org.eclipse.persistence.platform.JMXEnabledPlatform;
import org.eclipse.persistence.services.jboss.MBeanJBossRuntimeServices;
import org.eclipse.persistence.services.mbean.MBeanDevelopmentServices;
import org.eclipse.persistence.services.mbean.MBeanRuntimeServicesMBean;
import org.eclipse.persistence.services.websphere.MBeanWebSphereRuntimeServices;
import org.eclipse.persistence.sessions.DatabaseSession;
import org.eclipse.persistence.transaction.jboss.JBossTransactionController;

/**
 * PUBLIC:
 *
 * This is the concrete subclass responsible for representing WebSphere 7 -specific server behavior.
 * 7 -specific server behavior.
 *
 * This platform has:
 * - No JMX MBean runtime services

     */
    public WebSphere_7_Platform(DatabaseSession newDatabaseSession) {
        super(newDatabaseSession);
        this.enableRuntimeServices();
    }
    
    public boolean isJMXEnabled() {
        return true;
    }
    
    /**
     * INTERNAL: 
     * serverSpecificRegisterMBean(): Server specific implementation of the
     * creation and deployment of the JMX MBean to provide runtime services for my
     * databaseSession.
     *
     * @return void
     * @see #isRuntimeServicesEnabled()
     * @see #disableRuntimeServices()
     * @see #registerMBean()
     */
    public void serverSpecificRegisterMBean() {
        MBeanRuntimeServicesMBean runtimeBean = null;
        // No check for an existing cached MBean - we will replace it if it exists
        if(shouldRegisterRuntimeBean) {
            runtimeBean = new MBeanWebSphereRuntimeServices(getDatabaseSession());
        }
        genericRegisterMBean(runtimeBean);
    }
}

Lines 14-20 Link Here

(-)foundation/org.eclipse.persistence.core/src/org/eclipse/persistence/platform/server/was/WebSpherePlatform.java (-2 / +2 lines)
14		14
15	import org.eclipse.persistence.internal.security.PrivilegedAccessHelper;	15	import org.eclipse.persistence.internal.security.PrivilegedAccessHelper;
16	import org.eclipse.persistence.logging.SessionLog;	16	import org.eclipse.persistence.logging.SessionLog;
17	import org.eclipse.persistence.platform.server.ServerPlatformBase;	17	import org.eclipse.persistence.platform.server.JMXServerPlatformBase;
18	import org.eclipse.persistence.sessions.DatabaseSession;	18	import org.eclipse.persistence.sessions.DatabaseSession;
19		19
20	import java.lang.reflect.InvocationTargetException;	20	import java.lang.reflect.InvocationTargetException;
Lines 33-39 Link Here
33	* <li> DataSource connection unwrapping (Oracle JDBC API support)	33	* <li> DataSource connection unwrapping (Oracle JDBC API support)
34	* </ul>	34	* </ul>
35	*/	35	*/
36	public class WebSpherePlatform extends ServerPlatformBase {	36	public class WebSpherePlatform extends JMXServerPlatformBase {
37		37
38	/**	38	/**
39	* Cached WAS connection class used to reflectively check connections and unwrap them.	39	* Cached WAS connection class used to reflectively check connections and unwrap them.




 *       - 248746: Add getModuleName() implementation and new getApplicationName()
 *     05/07/2009-1.1.1 Dave Brosius 
 *       - 265755: [PATCH] Set application name correctly 
 *     06/22/2010-2.2 Michael O'Brien 
 *       - 316509: Move JMX MBean generic registration code up from specific platforms
 *       see <link>http://wiki.eclipse.org/EclipseLink/DesignDocs/316513</link>        
 ******************************************************************************/  
package org.eclipse.persistence.platform.server.wls;

import java.lang.reflect.Method;
import java.security.AccessController;

import javax.management.InstanceAlreadyExistsException;
import javax.management.InstanceNotFoundException;
import javax.management.MBeanRegistrationException;
import javax.management.MBeanServer;
import javax.management.MalformedObjectNameException;
import javax.management.ObjectInstance;
import javax.management.ObjectName;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

import org.eclipse.persistence.internal.security.PrivilegedAccessHelper;
import org.eclipse.persistence.internal.security.PrivilegedMethodInvoker;
import org.eclipse.persistence.logging.AbstractSessionLog;
import org.eclipse.persistence.logging.SessionLog;
import org.eclipse.persistence.services.mbean.MBeanRuntimeServicesMBean;
import org.eclipse.persistence.services.weblogic.MBeanWebLogicRuntimeServices;
import org.eclipse.persistence.sessions.DatabaseSession;


     */
    /** This JNDI address is for JMX MBean unregistration */    
    private static final String JMX_JNDI_RUNTIME_UNREGISTER = "java:comp/jmx/runtime";
    /** This is the prefix for all MBeans that are registered with their specific session name appended */
    private static final String JMX_REGISTRATION_PREFIX = "TopLink:Name=";
    // Secondary override properties can be set to disable MBean registration
    /** This System property "eclipselink.register.dev.mbean" when set to true will enable registration/unregistration of the DevelopmentServices MBean */
    public static final String JMX_REGISTER_DEV_MBEAN_PROPERTY = "eclipselink.register.dev.mbean";
    /** This System property "eclipselink.register.run.mbean" when set to true will enable registration/unregistration of the RuntimeServices MBean */    
    public static final String JMX_REGISTER_RUN_MBEAN_PROPERTY = "eclipselink.register.run.mbean";
    /** This persistence.xml or sessions.xml property is used to override the moduleName */
    protected static final String SERVER_SPECIFIC_MODULENAME_PROPERTY = "eclipselink.weblogic.moduleName"; 
    /** This persistence.xml or sessions.xml property is used to override the applicationName */
    protected static final String SERVER_SPECIFIC_APPLICATIONNAME_PROPERTY = "eclipselink.weblogic.applicationName"; 
    // Any value such as true will turn on the MBean
    protected boolean shouldRegisterDevelopmentBean = System.getProperty(JMX_REGISTER_DEV_MBEAN_PROPERTY) != null;
    protected boolean shouldRegisterRuntimeBean = System.getProperty(JMX_REGISTER_RUN_MBEAN_PROPERTY) != null;

    /**
     * The following constants and attributes are used during reflective API calls
     */
    /** Cache the WebLogic MBeanServer for performance */
    //private MBeanServer wlsMBeanServer = null;
    /** Cache the WebLogic ThreadPoolRuntime for performance */    
    private ObjectName wlsThreadPoolRuntime = null;
    /** The JMX context when running as a module */

    /** Search String in WebLogic ClassLoader for the application:persistence_unit name */
    private static final String WLS_CLASSLOADER_APPLICATION_PU_SEARCH_STRING_PREFIX = "annotation: ";
    
    /** moduleName determination is available during MBean registration only */
    private String moduleName = null;

    /** applicationName determination is available during MBean registration only */
    private String applicationName = null;
    
    /** cache the RuntimeServices MBean */
    private MBeanWebLogicRuntimeServices runtimeServicesMBean = null;    
    /**
     * INTERNAL:
     * Default Constructor: All behavior for the default constructor is inherited
     */
    public WebLogic_10_Platform(DatabaseSession newDatabaseSession) {
        super(newDatabaseSession);
        this.enableRuntimeServices();
    }

    public boolean isJMXEnabled() {
        return true;
    }
    
    /**
     * INTERNAL: 
     * serverSpecificRegisterMBean(): Server specific implementation of the

     * @see #disableRuntimeServices()
     * @see #registerMBean()
     */
    @Override
    public void serverSpecificRegisterMBean() {
        MBeanRuntimeServicesMBean runtimeBean = null;
        // No check for an existing cached MBean - we will replace it if it exists
        if(shouldRegisterRuntimeBean) {
            runtimeBean = new MBeanWebLogicRuntimeServices(getDatabaseSession());
        }
        genericRegisterMBean(runtimeBean);
        // get and cache module and application name during registration
        initializeApplicationNameAndModuleName();
        MBeanServer mBeanServerRuntime = null;      
        ObjectName name = null;      
        String sessionName = getMBeanSessionName();
        Context initialContext = null;        
        if (null != sessionName && (shouldRegisterDevelopmentBean || shouldRegisterRuntimeBean)) {
            try {
                initialContext = new InitialContext();
                mBeanServerRuntime = (MBeanServer) initialContext.lookup(JMX_JNDI_RUNTIME_REGISTER);
                // Attempt to register new mBean with the server
                if (shouldRegisterDevelopmentBean) {
                    try {
                        name = new ObjectName(JMX_REGISTRATION_PREFIX + "Development-" + sessionName + ",Type=Configuration");
                    } catch (MalformedObjectNameException mne) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", mne);
                    } catch (Exception exception) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", exception);
                    }

                    MBeanDevelopmentServices mbean = new MBeanDevelopmentServices(getDatabaseSession());
                    ObjectInstance info = null;
                    try {
                        info = mBeanServerRuntime.registerMBean(mbean, name);
                    } catch(InstanceAlreadyExistsException iaee) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", iaee);
                    } catch (MBeanRegistrationException registrationProblem) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", registrationProblem);
                    } catch (Exception e) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", e);
                    }
                    AbstractSessionLog.getLog().log(SessionLog.FINEST, "registered_mbean", info);
                }

                if (shouldRegisterRuntimeBean) {
                    try {
                        name = new ObjectName(JMX_REGISTRATION_PREFIX + "Session(" + sessionName + ")");                        
                    } catch (MalformedObjectNameException mne) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", mne);
                    } catch (Exception exception) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", exception);
                    }
                    
                    MBeanWebLogicRuntimeServices runtimeServices = new MBeanWebLogicRuntimeServices(getDatabaseSession());                    
                    ObjectInstance runtimeInstance = null;
                    try {
                        runtimeInstance = mBeanServerRuntime.registerMBean(runtimeServices, name);
                        runtimeServicesMBean = runtimeServices;
                    } catch(InstanceAlreadyExistsException iaee) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", iaee);
                    } catch (MBeanRegistrationException registrationProblem) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", registrationProblem);
                    } catch (Exception e) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", e);
                    }
                    AbstractSessionLog.getLog().log(SessionLog.FINEST, "registered_mbean", runtimeInstance);          
                }
            } catch (NamingException ne) {
                AbstractSessionLog.getLog().log(SessionLog.WARNING, "failed_to_find_mbean_server", ne);
            } catch (Exception exception) {
                AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", exception);
            } finally {
                // close the context
                // see http://forums.bea.com/thread.jspa?threadID=600004445
                // see http://e-docs.bea.com/wls/docs81/jndi/jndi.html#471919
                // see http://e-docs.bea.com/wls/docs100/jndi/jndi.html#wp467275
                try {
                    mBeanServerRuntime = null;
                    if(null != initialContext) {
                        initialContext.close();
                    }
                } catch (NamingException ne) {
                    // exceptions on context close will be ignored, the context will be GC'd                   
                }
            }
        }
    }

    /**
     * INTERNAL: 
     * serverSpecificUnregisterMBean(): Server specific implementation of the
     * de-registration of the JMX MBean from its server during session logout.
     *
     * @return void
     * @see #isRuntimeServicesEnabled()
     * @see #disableRuntimeServices()
     */
    public void serverSpecificUnregisterMBean() {
        MBeanServer mBeanServerRuntime = null;      
        ObjectName name = null;      
        String sessionName = getMBeanSessionName();
        Context initialContext = null;        
        if (null != sessionName && (shouldRegisterDevelopmentBean || shouldRegisterRuntimeBean)) {
            try {
                initialContext = new InitialContext();
                mBeanServerRuntime = (MBeanServer) initialContext.lookup(JMX_JNDI_RUNTIME_UNREGISTER);
                // Attempt to register new mBean with the server
                if (shouldRegisterDevelopmentBean) {
                    try {
                        name = new ObjectName(JMX_REGISTRATION_PREFIX + "Development_" + sessionName + ",Type=Configuration");
                    } catch (MalformedObjectNameException mne) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_unregistering_mbean", mne);
                    } catch (Exception exception) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_unregistering_mbean", exception);
                    }

                    AbstractSessionLog.getLog().log(SessionLog.FINEST, "unregistering_mbean", name);
                    try {
                        mBeanServerRuntime.unregisterMBean(name);
                    } catch(InstanceNotFoundException inf) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_unregistering_mbean", inf);
                    } catch (MBeanRegistrationException mbre) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_unregistering_mbean", mbre);                        
                    }                                        
                }

                if (shouldRegisterRuntimeBean) {
                    try {                        
                        name = new ObjectName(JMX_REGISTRATION_PREFIX + "Session(" + sessionName + ")");                        
                    } catch (MalformedObjectNameException mne) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_unregistering_mbean", mne);
                    } catch (Exception exception) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_unregistering_mbean", exception);
                    }

                    AbstractSessionLog.getLog().log(SessionLog.FINEST, "unregistering_mbean", name);
                    try {
                        mBeanServerRuntime.unregisterMBean(name);
                    } catch(InstanceNotFoundException inf) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_unregistering_mbean", inf);
                    } catch (MBeanRegistrationException registrationProblem) {
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_unregistering_mbean", registrationProblem);
                    }                              
                }
            } catch (NamingException ne) {
                AbstractSessionLog.getLog().log(SessionLog.WARNING, "failed_to_find_mbean_server", ne);
            } catch (Exception exception) {
                // Trap a possible WebLogic specific [weblogic.management.NoAccessRuntimeException]
                AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_unregistering_mbean", exception);
            } finally {
                // de reference the mbean
                runtimeServicesMBean = null;
                // close the context
                // see http://forums.bea.com/thread.jspa?threadID=600004445
                // see http://e-docs.bea.com/wls/docs81/jndi/jndi.html#471919
                // see http://e-docs.bea.com/wls/docs100/jndi/jndi.html#wp467275
                try {
                    mBeanServerRuntime = null;
                    if(null != initialContext) {
                        initialContext.close();
                    }
                } catch (NamingException ne) {
                    // exceptions on context close will be ignored, the context will be GC'd
                }
            }
        }
    }

    /**
     * INTERNAL: 
     * getModuleName(): Answer the name of the context-root of the application that this session is associated with.
     * Answer "unknown" if there is no module name available.
     * Default behavior is to return "unknown" - we override this behavior here for WebLogic.
     * 
     * There are 4 levels of implementation.
     * 1) use the property override weblogic.moduleName, or
     * 2) perform a reflective weblogic.work.executeThreadRuntime.getModuleName() call (build 10.3+), or
     * 3) extract the moduleName:persistence_unit from the weblogic classloader string representation (build 10.3), or
     * 3) defer to superclass - usually return "unknown"
     *
     * @return String moduleName
     */
    public String getModuleName() {        
        return this.moduleName;
    }
    
    /**
     * INTERNAL: 
     * getApplicationName(): Answer the name of the module (EAR name) that this session is associated with.
     * Answer "unknown" if there is no application name available.
     * Default behavior is to return "unknown" - we override this behavior here for WebLogic.
     * 
     * There are 4 levels of implementation.
     * 1) use the property override weblogic.applicationName, or
     * 2) perform a reflective weblogic.work.executeThreadRuntime.getApplicationName() call (build 10.3+), or
     * 3) extract the moduleName:persistence_unit from the weblogic classloader string representation (build 10.3), or
     * 3) defer to superclass - usually return "unknown"
     *
     * @return String applicationName
     */
    public String getApplicationName() {
        return this.applicationName;
    }
    
    /**
     * INTERNAL:
     * Get the applicationName and moduleName from the runtime WebLogic MBean reflectively
     * @return
     */
    private void initializeApplicationNameAndModuleName() {
        // Get property from persistence.xml or sessions.xml
        String jpaModuleName = (String)getDatabaseSession().getProperty(SERVER_SPECIFIC_MODULENAME_PROPERTY);
        String jpaApplicationName = (String)getDatabaseSession().getProperty(SERVER_SPECIFIC_APPLICATIONNAME_PROPERTY);      
        
        if (jpaModuleName != null) {
            setModuleName(jpaModuleName);
        } else {
            jpaModuleName = getModuleOrApplicationName(WLS_MODULE_NAME_GET_METHOD_NAME);
            
            // If we are running a version of WebLogic 10.3 that does not support ExecuteThreadRuntime (from 10.3+) then use the ClassLoader                    
            if(null != jpaModuleName && jpaModuleName.indexOf("@") != -1) {
                setModuleName(jpaModuleName.substring(jpaModuleName.indexOf("@") + 1));
            } else {
                setModuleName(jpaModuleName);
            }
        }

        if (jpaApplicationName != null) {
            setApplicationName(jpaApplicationName);
        } else {
            jpaApplicationName = getModuleOrApplicationName(WLS_APPLICATION_NAME_GET_METHOD_NAME);

            // defer to the superclass implementation            
            if(null == jpaApplicationName) {
                jpaApplicationName = super.getApplicationName();
             }
            
            // If we are running a version of WebLogic 10.3 that does not support ExecuteThreadRuntime (from 10.3+) then use the ClassLoader                    
            if(null != jpaApplicationName && jpaApplicationName.indexOf("@") > -1) {
                setApplicationName(jpaApplicationName.substring(jpaApplicationName.indexOf("@") + 1));
            } else {
                setApplicationName(jpaApplicationName);                
            }            
        }
        
        // TODO: remove: Final check for null values
        if(null == getApplicationName()) {
            setApplicationName(DEFAULT_SERVER_NAME_AND_VERSION);
        }
        if(null == getModuleName()) {
            setModuleName(DEFAULT_SERVER_NAME_AND_VERSION);
        }
        AbstractSessionLog.getLog().log(SessionLog.FINEST, "mbean_get_application_name", 
                getDatabaseSession().getName(), getApplicationName());
        AbstractSessionLog.getLog().log(SessionLog.FINEST, "mbean_get_module_name", 
                getDatabaseSession().getName(), getModuleName());
    }

    /**

	 *
     * @return String module|application Name from WLS
     */
    private String getModuleOrApplicationName(String getMethodName) {
        Object classLoaderOrString = null;//this.getDatabaseSession().getPlatform().getConversionManager().getLoader();
        Object executeThread = getExecuteThreadFromMBean();
        

     * @return application name or null if the name cannot be obtained
     */
    private Object getExecuteThreadFromMBean() {
        // Lazy load the MBeanServer instance
        if (wlsMBeanServer == null) {
            Context initialContext = null;
            try {
                initialContext = new InitialContext();
                try {
                    // The lookup string used depends on the context from which this class is being accessed, i.e. servlet, EJB, etc.
                    // In this case we do not know at runtime whether we are running as a module or not - so we try both lookups
                    // Try java:comp/env lookup  - normally used when the app is a module
                    wlsMBeanServer = (MBeanServer) initialContext.lookup(WLS_MODULE_ENV_CONTEXT_LOOKUP);
                } catch (NamingException e) {
                    // Lookup failed - try java:comp - this is the case when the application is not a module
                    try {
                        wlsMBeanServer = (MBeanServer) initialContext.lookup(WLS_NON_MODULE_CONTEXT_LOOKUP);
                    } catch (NamingException ne) {
                        /*
                         * If the MBeanServer lookup failed, continue and use the classloader as a backup method
                         */
                        AbstractSessionLog.getLog().log(SessionLog.WARNING, "jmx_mbean_runtime_services_mbeanserver_lookup_failed", ne);
                    }
                }
                
                
            } catch (NamingException nex) {
                AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_unregistering_mbean", nex);
            } finally {
                // close the context
                try {
                    if(null != initialContext) {
                        initialContext.close();
                    }
                } catch (NamingException ne) {
                    // exceptions on context close will be ignored, the context will be garbage collected
                }
            }
        }
        // Now that we know that the MBeanServer has been initialized - we use it
        // Initialize the threadPoolRuntime and get the executeThreadRuntime
        //this.getDatabaseSession().getPlatform().getConversionManager().getLoader();
        if (getMBeanServer() != null) {
            // Lazy load the ThreadPoolRuntime instance
            if (wlsThreadPoolRuntime == null) {
                try {
                    ObjectName service = new ObjectName(WLS_SERVICE_KEY);
                    ObjectName serverRuntime = (ObjectName) getMBeanServer().getAttribute(service, WLS_SERVER_RUNTIME);
                    wlsThreadPoolRuntime = (ObjectName) getMBeanServer().getAttribute(serverRuntime, WLS_THREADPOOL_RUNTIME);
                } catch (Exception ex) {
                    AbstractSessionLog.getLog().log(SessionLog.WARNING, "jmx_mbean_runtime_services_threadpool_initialize_failed", ex);                                        
                }

            if (wlsThreadPoolRuntime != null) {
                try {
                    // Perform a reflective getExecuteThread()
                    return getMBeanServer().invoke(wlsThreadPoolRuntime, 
                            WLS_EXECUTE_THREAD_GET_METHOD_NAME, 
                            new Object[] { Thread.currentThread().getName() }, new String[] { String.class.getName() });
                } catch (Exception ex) {

    }
    
    /**
     * Remove JMX reserved characters from the session name
     * @param aSession
     * @return
     */
    private String getMBeanSessionName() {
        // Check for a valid session - should never occur though        
        if(null != getDatabaseSession() && null != getDatabaseSession().getName()) {
            // remove any JMX reserved characters when the session name is file:/drive:/directory
            return getDatabaseSession().getName().replaceAll("[=,:]", "_");
        } else {
            AbstractSessionLog.getLog().log(SessionLog.WARNING, "session_key_for_mbean_name_is_null");
            return null;
        }
    }
    
    /**
     * Return the method for the WebLogic JDBC connection wrapper vendorConnection.
     * WLS 10.3.4.0 added a getVendorConnectionSafe that does not invalidate the connection,
     * so use this if available.

                }
            }
        }

        return this.vendorConnectionMethod;
    }
    





import org.eclipse.persistence.internal.security.PrivilegedAccessHelper;
import org.eclipse.persistence.logging.SessionLog;
import org.eclipse.persistence.platform.server.JMXServerPlatformBase;
import org.eclipse.persistence.platform.server.ServerPlatformBase;
import org.eclipse.persistence.sessions.DatabaseSession;
import org.eclipse.persistence.transaction.wls.WebLogicTransactionController;

 * information
 * </ul>
 */
public class WebLogicPlatform extends JMXServerPlatformBase {

    /**
     * Cached WLS connection class used to reflectively check connections and

     */
    public WebLogicPlatform(DatabaseSession newDatabaseSession) {
        super(newDatabaseSession);
        this.disableRuntimeServices();
    }

    /**

    }

    /**
     * INTERNAL: 
     * getApplicationName(): Answer the name of the module (EAR name) that this session is associated with.
     * Answer "unknown" if there is no application name available.
     * Default behavior is to return "unknown" - we override this behavior here for WebLogic.
     * 
     * There are 4 levels of implementation.
     * 1) use the property override weblogic.applicationName, or
     * 2) perform a reflective weblogic.work.executeThreadRuntime.getApplicationName() call (build 10.3+), or
     * 3) extract the moduleName:persistence_unit from the weblogic classloader string representation (build 10.3), or
     * 3) defer to superclass - usually return "unknown"
     *
     * @return String applicationName
     */
    public String getApplicationName() {
        return DEFAULT_SERVER_NAME_AND_VERSION;
    }
    
    /**
     * INTERNAL: getExternalTransactionControllerClass(): Answer the class of
     * external transaction controller to use for WebLogic. This is read-only.
     * 




/*******************************************************************************
 * Copyright (c) 1998, 2010 Oracle. All rights reserved.
 * This program and the accompanying materials are made available under the 
 * terms of the Eclipse Public License v1.0 and Eclipse Distribution License v. 1.0 
 * which accompanies this distribution. 
 * The Eclipse Public License is available at http://www.eclipse.org/legal/epl-v10.html
 * and the Eclipse Distribution License is available at 
 * http://www.eclipse.org/org/documents/edl-v10.php.
 *
 * Contributors:
 *     @author  mobrien
 *     @since   EclipseLink 2.2 enh# 316511
 *     06/22/2010-2.2 Michael O'Brien 
 *       - 316511: Add JBoss specific JMX MBean attributes and functions
 *       see <link>http://wiki.eclipse.org/EclipseLink/DesignDocs/316513</link>
 ******************************************************************************/  
package org.eclipse.persistence.services.jboss;

import org.eclipse.persistence.services.ClassSummaryDetailBase;

/**
 * The class is used internally by the Portable JMX Framework to convert 
 * model specific classes into Open Types so that the attributes of model class can
 * be exposed by MBeans.
 */
public class ClassSummaryDetail extends ClassSummaryDetailBase {

    public static final String COMPOSITE_TYPE_TYPENAME = "org.eclipse.persistence.services.jboss";
    public static final String COMPOSITE_TYPE_DESCRIPTION = "org.eclipse.persistence.services.jboss.ClassSummaryDetail";

    /**
     * Construct a ClassSummaryDetail instance. The PropertyNames annotation is used 
     * to be able to construct a ClassSummaryDetail instance out of a CompositeData
     * instance. See MXBeans documentation for more details.
     */
    public ClassSummaryDetail(String className, String cacheType, String configuredSize,String currentSize , String parentClassName) {
        super(className, cacheType, configuredSize, currentSize , parentClassName);
    }
}




/*******************************************************************************
 * Copyright (c) 1998, 2010 Oracle. All rights reserved.
 * This program and the accompanying materials are made available under the 
 * terms of the Eclipse Public License v1.0 and Eclipse Distribution License v. 1.0 
 * which accompanies this distribution. 
 * The Eclipse Public License is available at http://www.eclipse.org/legal/epl-v10.html
 * and the Eclipse Distribution License is available at 
 * http://www.eclipse.org/org/documents/edl-v10.php.
 *
 * Contributors:
 *     @author  mobrien
 *     @since   EclipseLink 2.2 enh# 316511
 *     06/22/2010-2.2 Michael O'Brien 
 *       - 316511: Add JBoss specific JMX MBean attributes and functions
 *       see <link>http://wiki.eclipse.org/EclipseLink/DesignDocs/316513</link>
 ******************************************************************************/  
package org.eclipse.persistence.services.jboss;

import java.util.ArrayList;
import java.util.Collections;
import java.util.Enumeration;
import java.util.HashMap;
import java.util.Hashtable;
import java.util.Iterator;
import java.util.Locale;
import java.util.Map;
import java.util.StringTokenizer;
import java.util.Vector;
import java.util.regex.PatternSyntaxException;

import javax.management.openmbean.CompositeData;
import javax.management.openmbean.CompositeDataSupport;
import javax.management.openmbean.CompositeType;
import javax.management.openmbean.OpenDataException;
import javax.management.openmbean.OpenType;
import javax.management.openmbean.SimpleType;
import javax.management.openmbean.TabularData;
import javax.management.openmbean.TabularDataSupport;
import javax.management.openmbean.TabularType;


import org.eclipse.persistence.descriptors.ClassDescriptor;
import org.eclipse.persistence.internal.databaseaccess.DatabaseAccessor;
import org.eclipse.persistence.internal.databaseaccess.DatasourcePlatform;
import org.eclipse.persistence.internal.helper.ClassConstants;
import org.eclipse.persistence.internal.helper.Helper;
import org.eclipse.persistence.internal.identitymaps.CacheIdentityMap;
import org.eclipse.persistence.internal.identitymaps.CacheKey;
import org.eclipse.persistence.internal.identitymaps.FullIdentityMap;
import org.eclipse.persistence.internal.identitymaps.HardCacheWeakIdentityMap;
import org.eclipse.persistence.internal.identitymaps.IdentityMap;
import org.eclipse.persistence.internal.identitymaps.NoIdentityMap;
import org.eclipse.persistence.internal.identitymaps.SoftCacheWeakIdentityMap;
import org.eclipse.persistence.internal.identitymaps.SoftIdentityMap;
import org.eclipse.persistence.internal.identitymaps.WeakIdentityMap;
import org.eclipse.persistence.internal.sessions.AbstractSession;
import org.eclipse.persistence.internal.sessions.DatabaseSessionImpl;
import org.eclipse.persistence.logging.AbstractSessionLog;
import org.eclipse.persistence.logging.DefaultSessionLog;
import org.eclipse.persistence.logging.JavaLog;
import org.eclipse.persistence.logging.SessionLog;
import org.eclipse.persistence.platform.server.jboss.JBossPlatform;
import org.eclipse.persistence.platform.server.wls.WebLogicPlatform;
import org.eclipse.persistence.services.RuntimeServices;
import org.eclipse.persistence.sessions.DatabaseLogin;
import org.eclipse.persistence.sessions.DefaultConnector;
import org.eclipse.persistence.sessions.server.ConnectionPool;
import org.eclipse.persistence.sessions.server.ServerSession;
import org.eclipse.persistence.tools.profiler.PerformanceProfiler;

/**
 * <p>
 * <b>Purpose</b>: Provide a dynamic interface into the EclipseLink Session.
 * <p>
 * <b>Description</b>: This class is meant to provide facilities for managing an EclipseLink session external
 * to EclipseLink over JMX.
 */
public class JBossRuntimeServices extends RuntimeServices {

    /**
     * PUBLIC:
     *  Default Constructor
     */
    public JBossRuntimeServices() {
        super();
    }

    /**
     *  PUBLIC:
     *  Create an instance of WebLogicRuntimeServices to be associated with the provided session
     *
     *  @param session The session to be used with these RuntimeServices
     *  @param String myBaseObjectName: "weblogic:....." (The JMX object name before it's wrapped in a ObjectName)
     */
    public JBossRuntimeServices(AbstractSession session) {
        super();
        this.session = session;
        this.updateDeploymentTimeData();
    }

    /**
     *  Create an instance of WebLogicRuntimeServices to be associated with the provided locale
     *
     *  The user must call setSession(Session) afterwards to define the session.
     */
    public JBossRuntimeServices(Locale locale) {
    }

    /**
     *  INTERNAL:
     *  Define the session that this instance is providing runtime services for
     *
     *  @param Session session The session to be used with these RuntimeServices
     */
    protected void setSession(AbstractSession newSession) {
        this.session = newSession;
        this.updateDeploymentTimeData();
    }

    /**
     * Answer the name of the EclipseLink session this MBean represents.
     */
    public String getSessionName() {
        return getSession().getName();
    }

    /**
     * Answer the type of the EclipseLink session this MBean represents.
     * Types include: "ServerSession", "DatabaseSession", "SessionBroker"
     */
    public String getSessionType() {
        return Helper.getShortClassName(getSession().getClass());
    }

    /**
     * Provide an instance of 2 Dimensional Array simulating tabular format information about all
     * classes in the session whose class names match the provided filter.
     *
     * The 2 Dimensional array contains each item with values being row object array. Each row object array 
     * represents EclipseLink class details info with respect to below attributes:  
     * ["Class Name", "Parent Class Name",  "Cache Type", "Configured Size", "Current Size"]
     *
     */
    public Object[][] getClassSummaryDetailsUsingFilter(String filter){
        try{
           return  tabularDataTo2DArray(buildClassSummaryDetailsUsingFilter(filter),new String[] {
               "Class Name", "Parent Class Name", "Cache Type", "Configured Size", "Current Size" });
        } catch (Exception exception) {
           AbstractSessionLog.getLog().log(SessionLog.SEVERE, "weblogic_mbean_runtime_exception", exception); 
        }
        return null;
    }
    
    /**
     * Provide a list of instance of ClassSummaryDetail containing information about the
     * classes in the session whose class names match the provided filter.
     *
     * ClassSummaryDetail is a model specific class that can be used internally by the Portable JMX Framework to
     * convert class attribute to JMX required open type, it has:-
     *    1. model specific type that needs to be converted : ["Class Name", "Parent Class Name",  "Cache Type", "Configured Size", "Current Size"]
     *    2. convert methods.  
     *
     * @param filter A comma separated list of strings to match against.
     * @return A ArrayList of instance of ClassSummaryDetail containing class information for the class names that match the filter.
     */
    public ArrayList <ClassSummaryDetail>  getClassSummaryDetailsUsingFilterArray(String filter) {
        // if the filter is null, return all the details
        if (filter == null) {
            return getClassSummaryDetailsArray();
        }

        try {
            Vector mappedClassNames = getMappedClassNamesUsingFilter(filter);
            String mappedClassName;
            ArrayList classSummaryDetails = new ArrayList<ClassSummaryDetail>();
            // Check if there aren't any classes mapped
            if (mappedClassNames.size() == 0) {
                return null;
            }

            // get details for each class, and add the details to the summary
            for (int index = 0; index < mappedClassNames.size(); index++) {
                mappedClassName = (String)mappedClassNames.elementAt(index);
                classSummaryDetails.add(buildLowlevelDetailsFor(mappedClassName));
            }
            return classSummaryDetails;
        } catch (Exception openTypeException) {
            AbstractSessionLog.getLog().log(SessionLog.SEVERE, "weblogic_mbean_runtime_exception", openTypeException);            
            openTypeException.printStackTrace();
        }

        // wait to get requirements from EM
        return null;
    }

    /**
     * Provide a list of instance of ClassSummaryDetail containing information about all
     * classes in the session.
     *
     * ClassSummaryDetail is a model specific class that can be used internally by the Portable JMX Framework to
     * convert class attribute to JMX required open type, it has:-
     *    1. model specific type that needs to be converted : ["Class Name", "Parent Class Name",  "Cache Type", "Configured Size", "Current Size"]
     *    2. convert methods.  
     *
     * @return A ArrayList of instance of ClassSummaryDetail containing class information for the class names that match the filter.
     */
    public ArrayList <ClassSummaryDetail> getClassSummaryDetailsArray() {
        try {            
            Vector mappedClassNames = getMappedClassNames();
            ArrayList classSummaryDetails = new ArrayList<ClassSummaryDetail>();            
            // Check if there aren't any classes mapped
            if (mappedClassNames.size() == 0) {
                return null;
            }

            // get details for each class, and add the details to the summary
            for (int index = 0; index < mappedClassNames.size(); index++) {
                String mappedClassName = (String)mappedClassNames.elementAt(index);
                classSummaryDetails.add(buildLowlevelDetailsFor(mappedClassName));
            }

            return classSummaryDetails;
        } catch (Exception openTypeException) {
            AbstractSessionLog.getLog().log(SessionLog.SEVERE, "weblogic_mbean_runtime_exception", openTypeException);
            openTypeException.printStackTrace();
        }

        // wait to get requirements from EM
        return null;
    }
    
    /**
     * PUBLIC: Provide an instance of 2 Dimensional Array simulating tabular format information about all
     * classes in the session.
     *
     * The 2 Dimensional array contains each item with values being row object array. Each row object array 
     * represents EclipseLink class details info with respect to below attributes:  
     * ["Class Name", "Parent Class Name",  "Cache Type", "Configured Size", "Current Size"]
     *
     */
    public Object[][] getClassSummaryDetails() {
        try{
           return tabularDataTo2DArray(buildClassSummaryDetails(),new String[] {
               "Class Name", "Parent Class Name", "Cache Type", "Configured Size", "Current Size" });
        } catch (Exception exception){
           AbstractSessionLog.getLog().log(SessionLog.SEVERE, "weblogic_mbean_runtime_exception", exception);
        }
        return null;
    }
    
    /**
     * INTERNAL:
     * Provide an instance of TabularData containing information about the
     * classes in the session whose class names match the provided filter.
     *
     * The TabularData contains rowData with values being CompositeData(s)
     *
     * CompositeData has:
     *    CompositeType: column names are ["Class Name", "Parent Class Name",  "Cache Type", "Configured Size", "Current Size"]
     *
     *  Each CompositeData can have get(myColumnName) sent to it.
     *
     *
     * @param filter A comma separated list of strings to match against.
     * @return A TabularData of information for the class names that match the filter.
     */
    private TabularData buildClassSummaryDetailsUsingFilter(String filter) {
        // if the filter is null, return all the details
        if (filter == null) {
            return buildClassSummaryDetails();
        }

        try {
            Vector mappedClassNames = getMappedClassNamesUsingFilter(filter);
            String mappedClassName;
            TabularDataSupport rowData = new TabularDataSupport(buildTabularTypeForClassSummaryDetails());
            // Check if there aren't any classes mapped
            if (mappedClassNames.size() == 0) {
                return null;
            }

            // get details for each class, and add the details to the summary
            for (int index = 0; index < mappedClassNames.size(); index++) {
                mappedClassName = (String)mappedClassNames.elementAt(index);
                String[] key = new String[] { mappedClassName };
                rowData.put(key, buildDetailsFor(mappedClassName, rowData.getTabularType().getRowType()));
            }
            return rowData;
        } catch (Exception exception) {
            AbstractSessionLog.getLog().log(SessionLog.SEVERE, "weblogic_mbean_runtime_exception", exception);
        }

        // wait to get requirements from EM
        return null;
    }

    /**
     * INTERNAL: 
     * Provide an instance of TabularData containing information about all
     * classes in the session.
     *
     * The TabularData contains rowData with values being CompositeData(s)
     *
     * CompositeData has:
     *    CompositeType: column names are ["Class Name", "Parent Class Name",  "Cache Type", "Configured Size", "Current Size"]
     *
     *  Each CompositeData can have get(myColumnName) sent to it.
     *
     */
    private TabularData buildClassSummaryDetails() {
        try {
            Vector mappedClassNames = getMappedClassNames();
            String mappedClassName;
            TabularDataSupport rowData = new TabularDataSupport(buildTabularTypeForClassSummaryDetails());
            // Check if there aren't any classes mapped
            if (mappedClassNames.size() == 0) {
                return null;
            }

            // get details for each class, and add the details to the summary
            for (int index = 0; index < mappedClassNames.size(); index++) {
                mappedClassName = (String)mappedClassNames.elementAt(index);
                String[] key = new String[] { mappedClassName };
                rowData.put(key, buildDetailsFor(mappedClassName, rowData.getTabularType().getRowType()));
            }

            return rowData;
        } catch (Exception exception) {
            AbstractSessionLog.getLog().log(SessionLog.SEVERE, "weblogic_mbean_runtime_exception", exception);
        }

        // wait to get requirements from EM
        return null;
    }

    /**
     * INTERNAL:
     * Answer the fully qualified names of the classes mapped in the session.
     * This uses the mappedClass from the CMPPolicy.
     *
     * @return java.util.Vector
     */
    
    private Vector getMappedClassNames() {
        Hashtable alreadyAdded = new Hashtable();
        Vector mappedClassNames = new Vector();
        String mappedClassName = null;

        Iterator descriptorsIterator = getSession().getProject().getDescriptors()
                .values().iterator();
        while (descriptorsIterator.hasNext()) {
            ClassDescriptor nextDescriptor = (ClassDescriptor) descriptorsIterator.next();

            // differentiate between a generated class and not, by comparing the descriptor's Java class
            if (nextDescriptor.getCMPPolicy() != null) {
                if (nextDescriptor.getCMPPolicy().getMappedClass() != null) {
                    mappedClassName = nextDescriptor.getCMPPolicy().getMappedClass().getName();
                }
            }

            if (mappedClassName == null) {
                mappedClassName = nextDescriptor.getJavaClassName();
            }
            if (alreadyAdded.get(mappedClassName) == null) {
                alreadyAdded.put(mappedClassName, Boolean.TRUE);
                mappedClassNames.addElement(mappedClassName);
            }
            mappedClassName = null;
        }
        return mappedClassNames;
    }

    /**
    *  INTERNAL:
    *  This method traverses the EclipseLink descriptors and returns a Vector of the descriptor's
    *   reference class names that match the provided filter. The filter is a comma separated
    *   list of strings to match against.
    *
    *   @param filter A comma separated list of strings to match against.
    *   @return A Vector of class names that match the filter.
    */
    public Vector getMappedClassNamesUsingFilter(String filter) {
        //Output Vector
        Vector outputVector = new Vector();

        //Input mapped class names
        Vector mappedClassNames = getMappedClassNames();

        //Input filter values
        ArrayList filters = new ArrayList();
        StringTokenizer lineTokens = new StringTokenizer(filter, ",");
        while (lineTokens.hasMoreTokens()) {
            filters.add(lineTokens.nextToken());
        }
        for (int i = 0; i < mappedClassNames.size(); i++) {
            String className = (String)mappedClassNames.get(i);
            String classNameLowerCase = ((String)mappedClassNames.get(i)).toLowerCase();
            for (int j = 0; j < filters.size(); j++) {
                String filterValue = (Helper.rightTrimString((String)filters.get(j)).trim()).toLowerCase();
                if (filterValue.indexOf('*') == 0) {
                    filterValue = filterValue.substring(1);
                }
                try {
                    //Note: String.matches(String regex) since jdk1.4
                    if (classNameLowerCase.matches(new StringBuffer().append("^.*").append(filterValue).append(".*$").toString())) {
                        if (!outputVector.contains(className)) {
                            outputVector.add(className);
                        }
                    }
                } catch (PatternSyntaxException exception) {
                    //regular expression syntax error
                    AbstractSessionLog.getLog().log(SessionLog.FINEST, "pattern_syntax_error", exception);
                }
            }
        }
        Collections.sort(outputVector);
        return outputVector;
    }

    /**
     * INTERNAL:
     * Answer the TabularType describing the TabularData that we return from
     * getCacheSummaryDetails() and getCacheSummaryDetails(String filter)
     *
     * This is mostly for the client side to see what kind of information is returned.
     *
     * @return javax.management.openmbean.TabularType
     */
    private TabularType buildTabularTypeForClassSummaryDetails() throws OpenDataException {
        return new TabularType(getSessionName(), "Session description", buildCompositeTypeForClassSummaryDetails(),
                new String[] { "Class Name" });
    }

    /**
     * INTERNAL:
     * Answer the CompositeType describing the CompositeData that we return for
     * each IdentityMap (or subclass).
     *
     * This is mostly for the client side to see what kind of information is returned.
     * @return javax.management.openmbean.CompositeType
     */
    private CompositeType buildCompositeTypeForClassSummaryDetails() throws OpenDataException {
        return new CompositeType("Class Details", "Details of class for Class Summary", new String[] { 
                "Class Name", "Parent Class Name", "Cache Type", "Configured Size", "Current Size" }, new String[] { 
                "Class Name", "Parent Class Name", "Cache Type", "Configured Size", "Current Size" }, new OpenType[] { 
                SimpleType.STRING, SimpleType.STRING, SimpleType.STRING, SimpleType.STRING, SimpleType.STRING });
    }

    /**
     * INTERNAL:
     * Answer the CompositeData containing the cache details for the given mappedClassName
     * This uses a CompositeDataSupport, which implements CompositeData
     *
     * @param String mappedClassName: fullyQualified class name of the class
     * @param CompositeType detailsType: describes the format of the returned CompositeData

     * @return javax.management.openmbean.CompositeData
     */
    private CompositeData buildDetailsFor(String mappedClassName, CompositeType detailsType) throws Exception {
        return new CompositeDataSupport(detailsType, buildLowlevelDetailsFor(mappedClassName));
    }

    /**
     * INTERNAL:
     * Helper to build a HashMap to help in the construction of a CompositeData
     *
     * @param String mappedClassName: fullyQualified class name of the class

     * @return HashMap
     */
    private HashMap buildLowlevelDetailsFor(String mappedClassName) {
        Class mappedClass = (Class)getSession().getDatasourcePlatform().getConversionManager().convertObject(mappedClassName, ClassConstants.CLASS);
        IdentityMap identityMap = getSession().getIdentityMapAccessorInstance().getIdentityMap(mappedClass);
        ClassDescriptor descriptor = getSession().getProject().getDescriptor(mappedClass);

        String cacheType = getCacheTypeFor(identityMap.getClass());
        String configuredSize = "" + identityMap.getMaxSize();
        String currentSize = "";

        //show the current size, including subclasses 
        currentSize = "" + identityMap.getSize(mappedClass, true);

        String parentClassName = "";

        boolean isChildDescriptor = descriptor.isChildDescriptor();

        HashMap details = new HashMap();

        details.put("Class Name", mappedClassName);
        details.put("Cache Type", (isChildDescriptor ? "" : cacheType));
        details.put("Configured Size", (isChildDescriptor ? "" : configuredSize));
        details.put("Current Size", currentSize);
        //If I have a parent class name, get it. Otherwise, leave blank
        if (descriptor.hasInheritance()) {
            if (descriptor.getInheritancePolicy().getParentDescriptor() != null) {
                parentClassName = descriptor.getInheritancePolicy().getParentClassName();
            }
        }
        details.put("Parent Class Name", parentClassName);

        return details;
    }

    /**
     * INTERNAL:
     * Helper to build a HashMap to help in the construction of a CompositeData
     *
     * @param String mappedClassName: fullyQualified class name of the class

     * @return HashMap
     */
    private ClassSummaryDetail buildLowlevelDetailsForNew(String mappedClassName) {
        Class mappedClass = (Class)getSession().getDatasourcePlatform().getConversionManager().convertObject(mappedClassName, ClassConstants.CLASS);
        IdentityMap identityMap = getSession().getIdentityMapAccessorInstance().getIdentityMap(mappedClass);
        ClassDescriptor descriptor = getSession().getProject().getDescriptor(mappedClass);

        String cacheType = getCacheTypeFor(identityMap.getClass());
        String configuredSize = "" + identityMap.getMaxSize();
        String currentSize = "";

        //show the current size, including subclasses 
        currentSize = "" + identityMap.getSize(mappedClass, true);

        String parentClassName = "";

        boolean isChildDescriptor = descriptor.isChildDescriptor();

        ClassSummaryDetail details = new ClassSummaryDetail(
                mappedClassName,
                (isChildDescriptor ? "" : cacheType),
                (isChildDescriptor ? "" : configuredSize),
                currentSize,
                parentClassName);

        return details;
    }
    
    /**
     * INTERNAL:
     * getCacheTypeFor: Give a more UI-friendly version of the cache type
     */
    private String getCacheTypeFor(Class identityMapClass) {
        if (identityMapClass == CacheIdentityMap.class) {
            return "Cache";
        } else if (identityMapClass == FullIdentityMap.class) {
            return "Full";
        } else if (identityMapClass == HardCacheWeakIdentityMap.class) {
            return "HardWeak";
        } else if (identityMapClass == NoIdentityMap.class) {
            return "None";
        } else if (identityMapClass == SoftCacheWeakIdentityMap.class) {
            return "SoftWeak";
        } else if (identityMapClass == WeakIdentityMap.class) {
            return "Weak";
        } else if (identityMapClass == SoftIdentityMap.class) {
            return "Soft";
        }
        return "N/A";
    }

    /**
     * getModuleName(): Answer the name of the context-root of the application that this session is associated with.
     * Answer "unknown" if there is no module name available.
     * Default behavior is to return "unknown"
     */
    public String getModuleName() {
        return ((DatabaseSessionImpl)getSession())
            .getServerPlatform().getModuleName();
    }

    
    /**
     * getApplicationName(): Answer the name of the module (EAR name) that this session is associated with.
     * Answer "unknown" if there is no application name available.
     * Default behavior is to return "unknown"
     */
    public String getApplicationName() {
        return ((JBossPlatform)((DatabaseSessionImpl)getSession())
                .getServerPlatform()).getApplicationName();
    }
    
    /**
     * PUBLIC: Answer the EclipseLink log level at deployment time. This is read-only.
     */
    public String getDeployedEclipseLinkLogLevel() {
        return getNameForLogLevel(getDeployedSessionLog().getLevel());
    }

    /**
     * PUBLIC: Answer the EclipseLink log level that is changeable.
     * This does not affect the log level in the project (i.e. The next
     * time the application is deployed, changes are forgotten)
     */
    public String getCurrentEclipseLinkLogLevel() {
        return getNameForLogLevel(this.getSession().getSessionLog().getLevel());
    }

    /**
     * PUBLIC: Set the EclipseLink log level to be used at runtime.
     *
     * This does not affect the log level in the project (i.e. The next
     * time the application is deployed, changes are forgotten)
     *
     * @param String newLevel: new log level
     */
    public synchronized void setCurrentEclipseLinkLogLevel(String newLevel) {
        this.getSession().setLogLevel(this.getLogLevelForName(newLevel));
    }

    /**
     * INTERNAL: Answer the name for the log level given.
     *
     * @return String (one of OFF, SEVERE, WARNING, INFO, CONFIG, FINE, FINER, FINEST, ALL)
     */
    private String getNameForLogLevel(int logLevel) {
        switch (logLevel) {
        case SessionLog.ALL:
            return SessionLog.ALL_LABEL;
        case SessionLog.SEVERE:
            return SessionLog.SEVERE_LABEL;
        case SessionLog.WARNING:
            return SessionLog.WARNING_LABEL;
        case SessionLog.INFO:
            return SessionLog.INFO_LABEL;
        case SessionLog.CONFIG:
            return SessionLog.CONFIG_LABEL;
        case SessionLog.FINE:
            return SessionLog.FINE_LABEL;
        case SessionLog.FINER:
            return SessionLog.FINER_LABEL;
        case SessionLog.FINEST:
            return SessionLog.FINEST_LABEL;
        case SessionLog.OFF:
            return SessionLog.OFF_LABEL;
        }
        return "N/A";
    }

    /**
     * INTERNAL: Answer the log level for the given name.
     *
     * @return int for OFF, SEVERE, WARNING, INFO, CONFIG, FINE, FINER, FINEST, ALL
     */
    private int getLogLevelForName(String levelName) {
        if (levelName.equals(SessionLog.ALL_LABEL)) {
            return SessionLog.ALL;
        }
        if (levelName.equals(SessionLog.SEVERE_LABEL)) {
            return SessionLog.SEVERE;
        }
        if (levelName.equals(SessionLog.WARNING_LABEL)) {
            return SessionLog.WARNING;
        }
        if (levelName.equals(SessionLog.INFO_LABEL)) {
            return SessionLog.INFO;
        }
        if (levelName.equals(SessionLog.CONFIG_LABEL)) {
            return SessionLog.CONFIG;
        }
        if (levelName.equals(SessionLog.FINE_LABEL)) {
            return SessionLog.FINE;
        }
        if (levelName.equals(SessionLog.FINER_LABEL)) {
            return SessionLog.FINER;
        }
        if (levelName.equals(SessionLog.FINEST_LABEL)) {
            return SessionLog.FINEST;
        }
        return SessionLog.OFF;
    }

    /**
     *     Method returns if all Parameters should be bound or not
     */
    public Boolean getShouldBindAllParameters() {
        if (!(getSession().getDatasourceLogin() instanceof DatabaseLogin)) {
            return Boolean.FALSE;
        }
        return Boolean.valueOf(((DatabaseLogin)getSession().getDatasourceLogin()).shouldBindAllParameters());
    }

    /**
      *     Return the size of strings after which will be bound into the statement
      *     If we are not using a DatabaseLogin, or we're not using string binding,
      *     answer 0 (zero).
      */
    public Integer getStringBindingSize() {
        if (!(getSession().getDatasourceLogin() instanceof DatabaseLogin)) {
            return Integer.valueOf(0);
        }
        if (!((DatabaseLogin)getSession().getDatasourceLogin()).getPlatform().usesStringBinding()) {
            return Integer.valueOf(0);
        }
        return Integer.valueOf(((DatabaseLogin)getSession().getDatasourceLogin()).getStringBindingSize());
    }

    /**
      *        This method will return if batchWriting is in use or not.
      */
    public Boolean getUsesBatchWriting() {
        return Boolean.valueOf(getSession().getDatasourceLogin().getPlatform().usesBatchWriting());
    }

    /**
      *        This method will return a long indicating the exact time in Milliseconds that the
      *   session connected to the database.
      */
    public Long getTimeConnectionEstablished() {
        return Long.valueOf(((DatabaseSessionImpl)getSession()).getConnectedTime());
    }

    /**
      *        This method will return if batchWriting is in use or not.
      */
    public Boolean getUsesJDBCBatchWriting() {
        return Boolean.valueOf(getSession().getDatasourceLogin().getPlatform().usesJDBCBatchWriting());
    }

    /**
      *     Shows if Byte Array Binding is turned on or not
      */
    public Boolean getUsesByteArrayBinding() {
        return Boolean.valueOf(getSession().getDatasourceLogin().getPlatform().usesByteArrayBinding());
    }

    /**
      *     Shows if native SQL is being used
      */
    public Boolean getUsesNativeSQL() {
        return Boolean.valueOf(getSession().getDatasourceLogin().getPlatform().usesNativeSQL());
    }

    /**
      *     This method indicates if streams are being used for binding
      */
    public Boolean getUsesStreamsForBinding() {
        return Boolean.valueOf(getSession().getDatasourceLogin().getPlatform().usesStreamsForBinding());
    }

    /**
      *     This method indicates if Strings are being bound
      */
    public Boolean getUsesStringBinding() {
        if (!(getSession().getDatasourceLogin() instanceof DatabaseLogin)) {
            return Boolean.FALSE;
        }
        return Boolean.valueOf(((DatabaseLogin)getSession().getDatasourceLogin()).getPlatform().usesStringBinding());
    }

    /**
    *     Returns if statements should be cached or not
    */
    public boolean getShouldCacheAllStatements() {
        if (!(getSession().getDatasourceLogin() instanceof DatabaseLogin)) {
            return Boolean.FALSE;
        }
        return Boolean.valueOf(((DatabaseLogin)getSession().getDatasourceLogin()).shouldCacheAllStatements());
    }

    /**
    *        Returns the statement cache size.  Only valid if statements are being cached
    */
    public int getStatementCacheSize() {
        if (!(getSession().getDatasourceLogin() instanceof DatabaseLogin)) {
            return 0;
        }
        return Integer.valueOf(((DatabaseLogin)getSession().getDatasourceLogin()).getStatementCacheSize());
    }

    /**
    *     Used to clear the statement cache. Only valid if statements are being cached
    */
    public synchronized void clearStatementCache() {
        if (!(getSession().getDatasourceLogin() instanceof DatabaseLogin)) {
            return;
        }
        ((DatabaseAccessor)getSession().getAccessor()).clearStatementCache(getSession());
        ((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_statement_cache_cleared");        
        
    }

    /**
    *        Method returns the value of the Sequence Preallocation size
    */
    public int getSequencePreallocationSize() {
        if (!(getSession().getDatasourceLogin() instanceof DatabaseLogin)) {
            return 0;
        }
        return ((DatasourcePlatform)getSession().getDatasourcePlatform()).getSequencePreallocationSize();        
    }

    /**
    *     This method will print the available Connection pools to the SessionLog.
    * @return void
    */
    public void printAvailableConnectionPools() {
        if (ClassConstants.ServerSession_Class.isAssignableFrom(getSession().getClass())) {
            Map pools = ((ServerSession)getSession()).getConnectionPools();
            Iterator poolNames = pools.keySet().iterator();
            while (poolNames.hasNext()) {
                String poolName = poolNames.next().toString();
                ((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_pool_name", poolName);
            }
        } else {
            ((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_no_connection_pools_available");            
            
        }
    }

    /**
    *     This method will retrieve the max size of a particular connection pool
    * @param poolName the name of the pool to get the max size for
    * @return Integer for the max size of the pool. Return -1 if pool doesn't exist.
    */
    public Integer getMaxSizeForPool(String poolName) {
        if (ClassConstants.ServerSession_Class.isAssignableFrom(getSession().getClass())) {
            ConnectionPool connectionPool = ((ServerSession)getSession()).getConnectionPool(poolName);
            if (connectionPool != null) {
                return Integer.valueOf(connectionPool.getMaxNumberOfConnections());
            }
        }
        return Integer.valueOf(-1);
    }

    /**
    *     This method will retrieve the min size of a particular connection pool
    * @param poolName the name of the pool to get the min size for
    * @return Integer for the min size of the pool. Return -1 if pool doesn't exist.
    */
    public Integer getMinSizeForPool(String poolName) {
        if (ClassConstants.ServerSession_Class.isAssignableFrom(getSession().getClass())) {
            ConnectionPool connectionPool = ((ServerSession)getSession()).getConnectionPool(poolName);
            if (connectionPool != null) {
                return Integer.valueOf(connectionPool.getMinNumberOfConnections());
            }
        }
        return Integer.valueOf(-1);
    }

    /**
    * This method is used to reset connections from the session to the database.  Please
    * Note that this will not work with a SessionBroker at this time
    */
    public synchronized void resetAllConnections() {
        if (ClassConstants.ServerSession_Class.isAssignableFrom(getSession().getClass())) {
            Iterator enumtr = ((ServerSession)getSession()).getConnectionPools().values().iterator();
            while (enumtr.hasNext()) {
                ConnectionPool pool = (ConnectionPool)enumtr.next();
                pool.shutDown();
                pool.startUp();
            }
        } else if (ClassConstants.PublicInterfaceDatabaseSession_Class.isAssignableFrom(getSession().getClass())) {
            getSession().getAccessor().reestablishConnection(getSession());
        }
    }

    /**
    *        This method is used to output those Class Names that have identity Maps in the Session.
    * Please note that SubClasses and aggregates will be missing from this list as they do not have
    * separate identity maps.
    * @return void
    */
    public void printClassesInSession() {
        Vector classes = getSession().getIdentityMapAccessorInstance().getIdentityMapManager().getClassesRegistered();
        int index;
        if (classes.isEmpty()) {
            ((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_no_classes_in_session");            
            return;
        }

        for (index = 0; index < classes.size(); index++) {
            getSession().getSessionLog().log(SessionLog.FINEST, (String)classes.elementAt(index));
        }
    }

    /**
    *        This method will log the objects in the Identity Map.
    * There is no particular order to these objects.
    * @param className the fully qualified classname identifying the identity map
    * @exception  thrown then the IdentityMap for that class name could not be found
    */
    public void printObjectsInIdentityMap(String className) throws ClassNotFoundException {
        Class classWithMap = (Class)getSession().getDatasourcePlatform().getConversionManager().convertObject(className, ClassConstants.CLASS);
        IdentityMap map = getSession().getIdentityMapAccessorInstance().getIdentityMap(classWithMap);

        //check if the identity map exists
        if (null == map) {
            ((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_identity_map_non_existent", className);
            return;
        }

        //check if there are any objects in the identity map. Print if so.
        Enumeration objects = map.keys();
        if (!objects.hasMoreElements()) {
            ((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_identity_map_empty", className);
        }

        CacheKey cacheKey;
        while (objects.hasMoreElements()) {
            cacheKey = (CacheKey)objects.nextElement();
            ((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_print_cache_key_value", 
                    cacheKey.getKey().toString(), cacheKey.getObject().toString());
        }
    }

    /**
    *        This method will log the types of Identity Maps in the session.
    */
    public void printAllIdentityMapTypes() {
        Vector classesRegistered = getSession().getIdentityMapAccessorInstance().getIdentityMapManager().getClassesRegistered();
        String registeredClassName;
        Class registeredClass;

        //Check if there aren't any classes registered
        if (classesRegistered.size() == 0) {
            ((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_no_identity_maps_in_session");
            return;
        }

        //get each identity map, and log the type
        for (int index = 0; index < classesRegistered.size(); index++) {
            registeredClassName = (String)classesRegistered.elementAt(index);
            registeredClass = (Class)getSession().getDatasourcePlatform().getConversionManager().convertObject(registeredClassName, ClassConstants.CLASS);
            IdentityMap map = getSession().getIdentityMapAccessorInstance().getIdentityMap(registeredClass);
            ((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_identity_map_class", 
                    registeredClassName, map.getClass());
        }
    }

    /**
    *        This method will log all objects in all Identity Maps in the session.
    */
    public void printObjectsInIdentityMaps() {
        Vector classesRegistered = getSession().getIdentityMapAccessorInstance().getIdentityMapManager().getClassesRegistered();
        String registeredClassName;

        //Check if there aren't any classes registered
        if (classesRegistered.size() == 0) {
            ((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_no_identity_maps_in_session");
            return;
        }

        //get each identity map, and log the type
        for (int index = 0; index < classesRegistered.size(); index++) {
            registeredClassName = (String)classesRegistered.elementAt(index);
            try {
                this.printObjectsInIdentityMap(registeredClassName);
            } catch (ClassNotFoundException classNotFound) {
                //we are enumerating registered classes, so this shouldn't happen. Print anyway
                classNotFound.printStackTrace();
                AbstractSessionLog.getLog().log(SessionLog.SEVERE, "weblogic_mbean_runtime_exception", classNotFound);
            }
        }
    }

    /**
    *        This method is used to return the number of objects in a particular Identity Map
    * @param className the fully qualified name of the class to get number of instances of.
    * @exception  thrown then the IdentityMap for that class name could not be found
    */
    public Integer getNumberOfObjectsInIdentityMap(String className) throws ClassNotFoundException {
        //BUG 3982060: Always use the root class in combination with the identity map's getSize(class, true) to get an accurate count
        Class classWithIdentityMap = (Class)getSession().getDatasourcePlatform().getConversionManager().convertObject(className, ClassConstants.CLASS);
        Class rootClass = null;

        ClassDescriptor descriptor = getSession().getDescriptor(classWithIdentityMap);
        ClassDescriptor rootDescriptor;

        if (descriptor.hasInheritance()) {
            rootDescriptor = descriptor.getInheritancePolicy().getRootParentDescriptor();
        } else {
            rootDescriptor = descriptor;
        }
        if (rootDescriptor.getCMPPolicy() != null) {
            if (rootDescriptor.getCMPPolicy().getMappedClass() != null) {
                rootClass = rootDescriptor.getCMPPolicy().getMappedClass();
            }
        }

        if (rootClass == null) {
            rootClass = rootDescriptor.getJavaClass();
        }

        return Integer.valueOf(getSession().getIdentityMapAccessorInstance().getIdentityMap(rootClass).getSize(rootClass, true));
    }

    /**
    *        This method will SUM and return the number of objects in all Identity Maps in the session.
    */
    public Integer getNumberOfObjectsInAllIdentityMaps() {
        Vector classesRegistered = getSession().getIdentityMapAccessorInstance().getIdentityMapManager().getClassesRegistered();
        String registeredClassName;
        int sum = 0;

        //Check if there aren't any classes registered
        if (classesRegistered.size() == 0) {
            ((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_no_identity_maps_in_session");
            return Integer.valueOf(0);
        }

        //get each identity map, and log the size
        for (int index = 0; index < classesRegistered.size(); index++) {
            registeredClassName = (String)classesRegistered.elementAt(index);
            try {
                sum += this.getNumberOfObjectsInIdentityMap(registeredClassName).intValue();
            } catch (ClassNotFoundException classNotFound) {
                //we are enumerating registered classes, so this shouldn't happen. Print anyway
                classNotFound.printStackTrace();
                AbstractSessionLog.getLog().log(SessionLog.SEVERE, "weblogic_mbean_runtime_exception", classNotFound);
            }
        }

        return Integer.valueOf(sum);
    }

    /**
     * This method will answer the number of persistent classes contained in the session.
     * This does not include aggregates.
     */
    public Integer getNumberOfPersistentClasses() {
        Hashtable classesTable = new Hashtable();
        ClassDescriptor currentDescriptor;

        //use a table to eliminate duplicate classes. Ignore Aggregates
        Iterator descriptors = getSession().getProject().getDescriptors().values().iterator();
        while (descriptors.hasNext()) {
            currentDescriptor = (ClassDescriptor)descriptors.next();
            if (!currentDescriptor.isAggregateDescriptor()) {
                classesTable.put(currentDescriptor.getJavaClassName(), Boolean.TRUE);
            }
        }

        return Integer.valueOf(classesTable.size());
    }


    /**
    * Return the log type, either "EclipseLink",  "Java" or the simple name of the logging class used.  
    *
    * @return the log type
    */
    public String getLogType() {
        if (this.getSession().getSessionLog().getClass() == JavaLog.class) {
            return "Java";
        } else if (this.getSession().getSessionLog().getClass() == DefaultSessionLog.class) {
            return EclipseLink_Product_Name;
        } else {
            return this.getSession().getSessionLog().getClass().getSimpleName();
        }
    }

    /**
    * Return the database platform used by the DatabaseSession.
    *
    * @return String databasePlatform
    */
    public String getDatabasePlatform() {
        return getSession().getDatasourcePlatform().getClass().getName();
    }

    /**
    *        Return JDBCConnection detail information. This includes URL and datasource information.
    */
    public synchronized String getJdbcConnectionDetails() {
        return getSession().getLogin().getConnector().getConnectionDetails();
    }

    /**
    *        Return connection pool type. Values include: "Internal", "External" and "N/A".
    */
    public synchronized String getConnectionPoolType() {
        if (getSession().getLogin().shouldUseExternalConnectionPooling()) {
            return "External";
        } else {
            return "N/A";
        }
    }

    /**
    *        Return db driver class name. This only applies to DefaultConnector. Return "N/A" otherwise.
    */
    public synchronized String getDriver() {
        if (getSession().getLogin().getConnector() instanceof DefaultConnector) {
            return getSession().getLogin().getDriverClassName();
        }
        return "N/A";
    }

    /**
    * Return the log filename. This returns the fully qualified path of the log file when
    * EclipseLink DefaultSessionLog instance is used. Null is returned otherwise.
    *
    * @return String logFilename
    */
    public String getLogFilename() {
        // returns String or null.
        if ( session.getSessionLog() instanceof DefaultSessionLog) {
                return ((DefaultSessionLog)session.getSessionLog()).getWriterFilename();
        } else {
            return null;
        }
    }

    /**
    *    This method is used to initialize the identity maps in the session.
    */
    public synchronized void initializeAllIdentityMaps() {
        getSession().getIdentityMapAccessor().initializeAllIdentityMaps();
    }

    /**
    *    This method is used to initialize the identity maps specified by the Vector of classNames.
    *
    * @param classNames String[] of fully qualified classnames identifying the identity maps to initialize
    */
    public synchronized void initializeIdentityMaps(String[] classNames) throws ClassNotFoundException {
        for (int index = 0; index < classNames.length; index++) {
            initializeIdentityMap(classNames[index]);
        }
    }

    /**
    *    This method is used to invalidate the identity maps in the session.
    */
    public synchronized void invalidateAllIdentityMaps() {
        Vector classesRegistered = getSession().getIdentityMapAccessorInstance().getIdentityMapManager().getClassesRegistered();
        String registeredClassName;
        Class registeredClass;

        if (classesRegistered.isEmpty()) {
            getSession().getSessionLog().info("There are no Identity Maps in this session");
            ((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_no_identity_maps_in_session");            
        }

        //get each identity map, and invalidate
        for (int index = 0; index < classesRegistered.size(); index++) {
            registeredClassName = (String)classesRegistered.elementAt(index);
            registeredClass = (Class)getSession().getDatasourcePlatform().getConversionManager()
                .convertObject(registeredClassName, ClassConstants.CLASS);
            getSession().getIdentityMapAccessor().invalidateClass(registeredClass);
            ((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_identity_map_invalidated", registeredClassName);
        }
    }

    /**
    *    This method is used to invalidate the identity maps specified by the String[] of classNames.
    *
    * @param classNames String[] of fully qualified classnames identifying the identity maps to invalidate
    * @param recurse    Boolean indicating if we want to invalidate the children identity maps too
    */
    public synchronized void invalidateIdentityMaps(String[] classNamesParam, Boolean recurse) throws ClassNotFoundException {
        String[] classNames = classNamesParam;
        for (int index = 0; index < classNames.length; index++) {
            invalidateIdentityMap(classNames[index], recurse);
        }
    }

    /**
    *    This method is used to invalidate the identity maps specified by className. This does not
    * invalidate the children identity maps
    *
    * @param className the fully qualified classname identifying the identity map to invalidate
    */
    public synchronized void invalidateIdentityMap(String className) throws ClassNotFoundException {
        this.invalidateIdentityMap(className, Boolean.FALSE);
    }

    /**
    *    This method is used to invalidate the identity maps specified by className.
    *
    * @param className the fully qualified classname identifying the identity map to invalidate
    * @param recurse    Boolean indicating if we want to invalidate the children identity maps too
    */
    public synchronized void invalidateIdentityMap(String className, Boolean recurse) throws ClassNotFoundException {
        Class registeredClass;

        //get identity map, and invalidate
        registeredClass = (Class)getSession().getDatasourcePlatform().getConversionManager()
            .convertObject(className, ClassConstants.CLASS);
        getSession().getIdentityMapAccessor().invalidateClass(registeredClass);
        ((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_identity_map_invalidated", className);
    }

    /**
     * 
    * INTERNAL:
     * Convert the TabularData to a two-dimensional array
     * @param tdata the TabularData to be converted
     * @param names the order of the columns
     * @return a two-dimensional array
     * @throws Exception
     */
    private Object[][] tabularDataTo2DArray(TabularData tdata, String[] names) throws Exception {
        if(tdata==null){
            return null;
        }
        Object[] rows = tdata.values().toArray();
        Object[][] data = new Object[rows.length][];

        for (int i=0; i<rows.length; i++) {
            data[i] = ((CompositeData) rows[i]).getAll(names);
        }
        return data;
    }
    
    
    /**
     * Return whether this session is an EclipseLink JPA session.
     * The absence of this function or a value of false will signify that the session
     * belongs to a provider other than EclipseLink.  
     * @return
     */
    public boolean isJPASession() {
        return true;
    }
}




/*******************************************************************************
 * Copyright (c) 1998, 2010 Oracle. All rights reserved.
 * This program and the accompanying materials are made available under the 
 * terms of the Eclipse Public License v1.0 and Eclipse Distribution License v. 1.0 
 * which accompanies this distribution. 
 * The Eclipse Public License is available at http://www.eclipse.org/legal/epl-v10.html
 * and the Eclipse Distribution License is available at 
 * http://www.eclipse.org/org/documents/edl-v10.php.
 *
 * Contributors:
 *     @author  mobrien
 *     @since   EclipseLink 2.2 enh# 316511
 *     06/22/2010-2.2 Michael O'Brien 
 *       - 316511: Add JBoss specific JMX MBean attributes and functions
 *       see <link>http://wiki.eclipse.org/EclipseLink/DesignDocs/316513</link>
 ******************************************************************************/  
package org.eclipse.persistence.services.jboss;

import org.eclipse.persistence.internal.sessions.AbstractSession;
import org.eclipse.persistence.sessions.Session;

/**
 * <p>
 * <b>Purpose</b>: Provide a dynamic interface into the EclipseLink Session.
 * <p>
 * <b>Description</b>: This class is meant to provide a framework for gaining access to configuration
 * of the EclipseLink Session during runtime.  It will provide the basis for development
 * of a JMX service and possibly other frameworks.
 */
public class MBeanJBossRuntimeServices extends JBossRuntimeServices implements MBeanJBossRuntimeServicesMBean {
    public MBeanJBossRuntimeServices(Session session) {
        super((AbstractSession)session);
    }
}




/*******************************************************************************
 * Copyright (c) 1998, 2010 Oracle. All rights reserved.
 * This program and the accompanying materials are made available under the 
 * terms of the Eclipse Public License v1.0 and Eclipse Distribution License v. 1.0 
 * which accompanies this distribution. 
 * The Eclipse Public License is available at http://www.eclipse.org/legal/epl-v10.html
 * and the Eclipse Distribution License is available at 
 * http://www.eclipse.org/org/documents/edl-v10.php.
 *
 * Contributors:
 *     @author  mobrien
 *     @since   EclipseLink 2.2 enh# 316511
 *     06/22/2010-2.2 Michael O'Brien 
 *       - 316511: Add JBoss specific JMX MBean attributes and functions
 *       see <link>http://wiki.eclipse.org/EclipseLink/DesignDocs/316513</link>
 ******************************************************************************/  
package org.eclipse.persistence.services.jboss;

import java.util.ArrayList;
import java.util.Vector;

import org.eclipse.persistence.services.mbean.MBeanRuntimeServicesMBean;

/**
 * <p>
 * <b>Purpose</b>: Provide a dynamic interface into the EclipseLink Session.
 * <p>
 * <b>Description</b>: This class is meant to provide facilities for managing an EclipseLink session external
 * to EclipseLink over JMX.
 */
public interface MBeanJBossRuntimeServicesMBean extends MBeanRuntimeServicesMBean {
    /**
     *  Answer the name of the EclipseLink session this MBean represents.
     */
    public String getSessionName();

    /**
     *  Answer the type of the EclipseLink session this MBean represents.
     * Types include: "ServerSession", "DatabaseSession", "SessionBroker"
     */
    public String getSessionType();

    /**
     *  Provide an instance of 2 Dimensional Array simulating tabular format information about all
     * classes in the session whose class names match the provided filter.
     *
     * The 2 Dimensional array contains each item with values being row object array. Each row object array 
     * represents EclipseLink class details info with respect to below attributes:  
     * ["Class Name", "Parent Class Name",  "Cache Type", "Configured Size", "Current Size"]
     *
     */
    public Object[][] getClassSummaryDetailsUsingFilter(String filter);
    
    /**
     *  Provide an instance of 2 Dimensional Array simulating tabular format information about all
     * classes in the session.
     *
     * The 2 Dimensional array contains each item with values being row object array. Each row object array 
     * represents EclipseLink class details info with respect to below attributes:  
     * ["Class Name", "Parent Class Name",  "Cache Type", "Configured Size", "Current Size"]
     *
     */
    public Object[][] getClassSummaryDetails();
    
    /**
     *  Provide a list of instance of ClassSummaryDetail containing information about the
     * classes in the session whose class names match the provided filter.
     *
     * ClassSummaryDetail is a model specific class that can be used internally by the Portable JMX Framework to
     * convert class attribute to JMX required open type, it has:-
     *    1. model specific type that needs to be converted : ["Class Name", "Parent Class Name",  "Cache Type", "Configured Size", "Current Size"]
     *    2. convert methods.  
     *
     * @param filter A comma separated list of strings to match against.
     * @return A ArrayList of instance of ClassSummaryDetail containing class information for the class names that match the filter.
     */
    public ArrayList <ClassSummaryDetail>  getClassSummaryDetailsUsingFilterArray(String filter);
    
    /**
     *  Provide a list of instance of ClassSummaryDetail containing information about all
     * classes in the session.
     *
     * ClassSummaryDetail is a model specific class that can be used internally by the Portable JMX Framework to
     * convert class attribute to JMX required open type, it has:-
     *    1. model specific type that needs to be converted : ["Class Name", "Parent Class Name",  "Cache Type", "Configured Size", "Current Size"]
     *    2. convert methods.  
     *
     * @return A ArrayList of instance of ClassSummaryDetail containing class information for the class names that match the filter.
     */
    public ArrayList <ClassSummaryDetail>  getClassSummaryDetailsArray();

    /**
    *  INTERNAL:
    *  This method traverses the EclipseLink descriptors and returns a Vector of the descriptor's
    *   reference class names that match the provided filter. The filter is a comma separated
    *   list of strings to match against.
    *
    *   @param filter A comma separated list of strings to match against.
    *   @return A Vector of class names that match the filter.
    */
    public Vector getMappedClassNamesUsingFilter(String filter);

    /**
     * getModuleName(): Answer the name of the context-root of the application that this session is associated with.
     * Answer "unknown" if there is no module name available.
     * Default behavior is to return "unknown" 
     */
    public String getModuleName();
    
    /**
     * getApplicationName(): Answer the name of the module (EAR name) that this session is associated with.
     * Answer "unknown" if there is no application name available.
     * Default behavior is to return "unknown"
     */
    public String getApplicationName();

    /**
     *  Answer the EclipseLink log level at deployment time. This is read-only.
     */
    public String getDeployedEclipseLinkLogLevel();

    /**
     *  Answer the EclipseLink log level that is changeable.
     * This does not affect the log level in the project (i.e. The next
     * time the application is deployed, changes are forgotten)
     */
    public String getCurrentEclipseLinkLogLevel();

    /**
     *  Set the EclipseLink log level to be used at runtime.
     *
     * This does not affect the log level in the project (i.e. The next
     * time the application is deployed, changes are forgotten)
     *
     * @param String newLevel: new log level
     */
    public  void setCurrentEclipseLinkLogLevel(String newLevel);

    /**
    *        This method is used to get the type of profiling.
    *   Possible values are: "EclipseLink" or "None".
    */
    public  String getProfilingType();

    /**
    *        This method is used to select the type of profiling.
    *   Valid values are: "EclipseLink" or "None". These values are not case sensitive.
    *   null is considered  to be "None".
    */
    public  void setProfilingType(String profileType);

    /**
    *        This method is used to turn on EclipseLink Performance Profiling
    */
    public void setUseEclipseLinkProfiling();

    /**
    *        This method answers true if EclipseLink Performance Profiling is on.
    */
    public Boolean getUsesEclipseLinkProfiling();

    /**
    *        This method is used to turn off all Performance Profiling, DMS or EclipseLink.
    */
    public void setUseNoProfiling();

    /**
      *     Return the size of strings after which will be bound into the statement
      *     If we are not using a DatabaseLogin, or we're not using string binding,
      *     answer 0 (zero).
      */
    public Integer getStringBindingSize();

    /**
      *        This method will return a long indicating the exact time in Milliseconds that the
      *   session connected to the database.
      */
    public Long getTimeConnectionEstablished();

    /**
      *        This method will return if batchWriting is in use or not.
      */
    public Boolean getUsesJDBCBatchWriting();

    /**
      *     Shows if Byte Array Binding is turned on or not
      */
    public Boolean getUsesByteArrayBinding();

    /**
      *     Shows if native SQL is being used
      */
    public Boolean getUsesNativeSQL();

    /**
      *     This method indicates if streams are being used for binding
      */
    public Boolean getUsesStreamsForBinding();

    /**
      *     This method indicates if Strings are being bound
      */
    public Boolean getUsesStringBinding();

    /**
    *     Used to clear the statement cache. Only valid if statements are being cached
    */
    public  void clearStatementCache();

    /**
    *     This method will print the available Connection pools to the SessionLog.
    * @return void
    */
    public void printAvailableConnectionPools();

    /**
    *     This method will retrieve the max size of a particular connection pool
    * @param poolName the name of the pool to get the max size for
    * @return Integer for the max size of the pool. Return -1 if pool doesn't exist.
    */
    public Integer getMaxSizeForPool(String poolName);

    /**
    *     This method will retrieve the min size of a particular connection pool
    * @param poolName the name of the pool to get the min size for
    * @return Integer for the min size of the pool. Return -1 if pool doesn't exist.
    */
    public Integer getMinSizeForPool(String poolName);

    /**
    *        This method is used to output those Class Names that have identity Maps in the Session.
    * Please note that SubClasses and aggregates will be missing form this list as they do not have
    * separate identity maps.
    * @return void
    */
    public void printClassesInSession();

    /**
    *        This method will log the objects in the Identity Map.
    * There is no particular order to these objects.
    * @param className the fully qualified classname identifying the identity map
    * @exception  thrown then the IdentityMap for that class name could not be found
    */
    public void printObjectsInIdentityMap(String className) throws ClassNotFoundException;

    /**
    *        This method will log the types of Identity Maps in the session.
    */
    public void printAllIdentityMapTypes();

    /**
    *        This method will log all objects in all Identity Maps in the session.
    */
    public void printObjectsInIdentityMaps();

    /**
    *        This method will SUM and return the number of objects in all Identity Maps in the session.
    */
    public Integer getNumberOfObjectsInAllIdentityMaps();

    /**
    *        This method will answer the number of persistent classes contained in the session.
    *   This does not include aggregates.
    */
    public Integer getNumberOfPersistentClasses();

    /**
    *        This method will log the instance level locks in all Identity Maps in the session.
    */
    public void printIdentityMapLocks();

    /**
    *        This method will log the instance level locks in the Identity Map for the given class in the session.
    */
    public void printIdentityMapLocks(String registeredClassName);

    /**
    *        This method assumes EclipseLink Profiling (as opposed to Java profiling).
    *        This will log at the INFO level a summary of all elements in the profile.
    */
    public void printProfileSummary();

    /**
    *        This method assumes EclipseLink Profiling (as opposed to Java profiling).
    *        This will log at the INFO level a summary of all elements in the profile, categorized
    *        by Class.
    */
    public void printProfileSummaryByClass();

    /**
    *        This method assumes EclipseLink Profiling (as opposed to Java profiling).
    *        This will log at the INFO level a summary of all elements in the profile, categorized
    *        by Query.
    */
    public void printProfileSummaryByQuery();

    /**
    * Return the log type, either "EclipseLink",  "Java" or the simple name of the logging class used.  
    * @return the log type
    */
    public String getLogType();

    /**
    * Return the database platform used by the DatabaseSession.
    * @return String databasePlatform
    */
    public String getDatabasePlatform();

    /**
    * Return JDBCConnection detail information. This includes URL and datasource information.
    */
    public  String getJdbcConnectionDetails();

    /**
    * Return connection pool type. Values include: "Internal", "External" and "N/A".
    */
    public  String getConnectionPoolType();

    /**
    * Return db driver class name. This only applies to DefaultConnector. Return "N/A" otherwise.
    */
    public  String getDriver();

    /**
    * Return the log filename. This returns the fully qualified path of the log file when
    * EclipseLink logging is enabled. Null is returned otherwise.
    *
    * @return String logFilename
    */
    public String getLogFilename();

    /**
    *    This method is used to initialize the identity maps in the session.
    */
    public void initializeAllIdentityMaps();

    /**
    *    This method is used to initialize the identity maps specified by the Vector of classNames.
    *
    * @param classNames String[] of fully qualified classnames identifying the identity maps to initialize
    */
    public void initializeIdentityMaps(String[] classNames) throws ClassNotFoundException;

    /**
    *    This method is used to initialize the identity maps specified by className.
    * @param className the fully qualified classnames identifying the identity map to initialize
    */
    public void initializeIdentityMap(String className) throws ClassNotFoundException;

    /**
    *    This method is used to invalidate the identity maps in the session.
    */
    public void invalidateAllIdentityMaps();

    /**
    *    This method is used to invalidate the identity maps specified by the String[] of classNames.
    * @param classNames String[] of fully qualified classnames identifying the identity maps to invalidate
    * @param recurse    Boolean indicating if we want to invalidate the children identity maps too
    */
    public void invalidateIdentityMaps(String[] classNamesParam, Boolean recurse) throws ClassNotFoundException;

    /**
    *    This method is used to invalidate the identity maps specified by className. This does not
    * invalidate the children identity maps
    * @param className the fully qualified classname identifying the identity map to invalidate
    */
    public void invalidateIdentityMap(String className) throws ClassNotFoundException;

    /**
    *    This method is used to invalidate the identity maps specified by className.
    * @param className the fully qualified classname identifying the identity map to invalidate
    * @param recurse    Boolean indicating if we want to invalidate the children identity maps too
    */
    public void invalidateIdentityMap(String className, Boolean recurse) throws ClassNotFoundException;

    /**
     * Return whether this session is an EclipseLink JPA session.
     * The absence of this function or a value of false will signify that the session
     * belongs to a provider other than EclipseLink.  
     * @return
     */
    public boolean isJPASession();
    
}

Lines 27-32 Link Here

(-)foundation/org.eclipse.persistence.core/src/org/eclipse/persistence/services/RuntimeServices.java (+176 lines)
27	import org.eclipse.persistence.internal.identitymaps.HardCacheWeakIdentityMap;	27	import org.eclipse.persistence.internal.identitymaps.HardCacheWeakIdentityMap;
28	import org.eclipse.persistence.internal.identitymaps.IdentityMap;	28	import org.eclipse.persistence.internal.identitymaps.IdentityMap;
29	import org.eclipse.persistence.internal.sessions.AbstractSession;	29	import org.eclipse.persistence.internal.sessions.AbstractSession;
		30	import org.eclipse.persistence.logging.AbstractSessionLog;
		31	import org.eclipse.persistence.logging.SessionLog;
30	import org.eclipse.persistence.sessions.DatabaseLogin;	32	import org.eclipse.persistence.sessions.DatabaseLogin;
31	import org.eclipse.persistence.sessions.Session;	33	import org.eclipse.persistence.sessions.Session;
32	import org.eclipse.persistence.sessions.server.ConnectionPool;	34	import org.eclipse.persistence.sessions.server.ConnectionPool;
Lines 48-53 Link Here
48	/** stores access to the session object that we are controlling */	50	/** stores access to the session object that we are controlling */
49	protected Session session;	51	protected Session session;
50		52
		53	/** This is the profile weight at server startup time. This is read-only */
		54	private int deployedSessionProfileWeight;
		55
		56	/** This contains the session log from server startup time. This is read-only. */
		57	private SessionLog deployedSessionLog;
		58
		59	public String objectName;
		60
		61	protected static final String EclipseLink_Product_Name = "EclipseLink";
		62
51	/**	63	/**
52	* Default Constructor	64	* Default Constructor
53	*/	65	*/
Lines 406-409 Link Here
406	getSession().getProfiler().setProfileWeight(weight);	418	getSession().getProfiler().setProfileWeight(weight);
407	}	419	}
408	}	420	}
		421
		422	/**
		423	* This method is used to initialize the identity maps specified by className.
		424	* @param className the fully qualified classnames identifying the identity map to initialize
		425	*/
		426	public synchronized void initializeIdentityMap(String className) throws ClassNotFoundException {
		427	Class registeredClass;
		428
		429	//get identity map, and initialize
		430	registeredClass = (Class)getSession().getDatasourcePlatform().getConversionManager()
		431	.convertObject(className, ClassConstants.CLASS);
		432	getSession().getIdentityMapAccessor().initializeIdentityMap(registeredClass);
		433	((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_identity_map_initialized", className);
		434	}
		435
		436	/**
		437	* This method will log the instance level locks in all Identity Maps in the session.
		438	*/
		439	public void printIdentityMapLocks() {
		440	getSession().getIdentityMapAccessorInstance().getIdentityMapManager().printLocks();
		441	}
		442
		443	/**
		444	* This method will log the instance level locks in the Identity Map for the given class in the session.
		445	*/
		446	public void printIdentityMapLocks(String registeredClassName) {
		447	Class registeredClass = (Class)getSession().getDatasourcePlatform().getConversionManager()
		448	.convertObject(registeredClassName, ClassConstants.CLASS);
		449	getSession().getIdentityMapAccessorInstance().getIdentityMapManager().printLocks(registeredClass);
		450	}
		451
		452	/**
		453	* This method assumes EclipseLink Profiling (as opposed to Java profiling).
		454	* This will log at the INFO level a summary of all elements in the profile.
		455	*/
		456	public void printProfileSummary() {
		457	if (!this.getUsesEclipseLinkProfiling().booleanValue()) {
		458	return;
		459	}
		460	PerformanceProfiler performanceProfiler = (PerformanceProfiler)getSession().getProfiler();
		461	getSession().getSessionLog().info(performanceProfiler.buildProfileSummary().toString());
		462	}
		463
		464	/**
		465	* INTERNAL:
		466	* utility method to get rid of leading and trailing {}'s
		467	*/
		468	private String trimProfileString(String originalProfileString) {
		469	String trimmedString;
		470
		471	if (originalProfileString.length() > 1) {
		472	trimmedString = originalProfileString.substring(0, originalProfileString.length());
		473	if ((trimmedString.charAt(0) == '{') && (trimmedString.charAt(trimmedString.length() - 1) == '}')) {
		474	trimmedString = trimmedString.substring(1, trimmedString.length() - 1);
		475	}
		476	return trimmedString;
		477	} else {
		478	return originalProfileString;
		479	}
		480	}
		481
		482	/**
		483	* This method assumes EclipseLink Profiling (as opposed to Java profiling).
		484	* This will log at the INFO level a summary of all elements in the profile, categorized
485	* by Class.
486	*/
487	public void printProfileSummaryByClass() {
488	if (!this.getUsesEclipseLinkProfiling().booleanValue()) {
489	return;
490	}
491	PerformanceProfiler performanceProfiler = (PerformanceProfiler)getSession().getProfiler();
492	//trim the { and } from the beginning at end, because they cause problems for the logger
493	getSession().getSessionLog().info(trimProfileString(performanceProfiler.buildProfileSummaryByClass().toString()));
494	}
495
496	/**
497	* This method assumes EclipseLink Profiling (as opposed to Java profiling).
498	* This will log at the INFO level a summary of all elements in the profile, categorized
499	* by Query.
500	*/
501	public void printProfileSummaryByQuery() {
502	if (!this.getUsesEclipseLinkProfiling().booleanValue()) {
503	return;
504	}
505	PerformanceProfiler performanceProfiler = (PerformanceProfiler)getSession().getProfiler();
506	getSession().getSessionLog().info(trimProfileString(performanceProfiler.buildProfileSummaryByQuery().toString()));
507	}
508
509	/**
510	* This method is used to get the type of profiling.
511	* Possible values are: "EclipseLink" or "None".
512	*/
513	public synchronized String getProfilingType() {
514	if (getUsesEclipseLinkProfiling().booleanValue()) {
515	return EclipseLink_Product_Name;
516	} else {
517	return "None";
518	}
519	}
520
521	/**
522	* This method is used to select the type of profiling.
523	* Valid values are: "EclipseLink" or "None". These values are not case sensitive.
524	* null is considered to be "None".
525	*/
526	public synchronized void setProfilingType(String profileType) {
527	if ((profileType == null) \|\| (profileType.compareToIgnoreCase("None") == 0)) {
528	this.setUseNoProfiling();
529	} else if (profileType.compareToIgnoreCase(EclipseLink_Product_Name) == 0) {
530	this.setUseEclipseLinkProfiling();
531	}
532	}
533
534	/**
535	* This method is used to turn on EclipseLink Performance Profiling
536	*/
537	public void setUseEclipseLinkProfiling() {
538	if (getUsesEclipseLinkProfiling().booleanValue()) {
539	return;
540	}
541	getSession().setProfiler(new PerformanceProfiler());
542	}
543
544
545	/**
546	* This method is used to turn off all Performance Profiling, DMS or EclipseLink.
547	*/
548	public void setUseNoProfiling() {
549	getSession().setProfiler(null);
550	}
551
552	/**
553	* This method answers true if EclipseLink Performance Profiling is on.
554	*/
555	public Boolean getUsesEclipseLinkProfiling() {
556	return Boolean.valueOf(getSession().getProfiler() instanceof PerformanceProfiler);
557	}
558
559	/**
560	* INTERNAL:
561	* Define the deployment time data associated with logging and profiling
562	*
563	*/
564	protected void updateDeploymentTimeData() {
565	this.deployedSessionLog = (SessionLog)((AbstractSessionLog)session.getSessionLog()).clone();
566	if (session.getProfiler() == null) {
567	this.deployedSessionProfileWeight = -1;//there is no profiler
568	} else {
569	this.deployedSessionProfileWeight = session.getProfiler().getProfileWeight();
570	}
571	}
572
573	public int getDeployedSessionProfileWeight() {
574	return deployedSessionProfileWeight;
575	}
576
577	public SessionLog getDeployedSessionLog() {
578	return deployedSessionLog;
579	}
580
581	public String getObjectName() {
582	return objectName;
583	}
584
409	}	585	}




 ******************************************************************************/  
package org.eclipse.persistence.services.weblogic;

import org.eclipse.persistence.services.ClassSummaryDetailBase;

import javax.management.openmbean.CompositeType;
import javax.management.openmbean.SimpleType;
import javax.management.openmbean.OpenType;
import javax.management.openmbean.CompositeData;
import javax.management.openmbean.CompositeDataSupport;
import javax.management.openmbean.OpenDataException;

/**
 * The class is used internally by the Portable JMX Framework to convert 
 * model specific classes into Open Types so that the attributes of model class can
 * be exposed by MBeans.
 */
public class ClassSummaryDetail extends ClassSummaryDetailBase {

    public static final String COMPOSITE_TYPE_TYPENAME = "org.eclipse.persistence.services.weblogic";
    public static final String COMPOSITE_TYPE_DESCRIPTION = "org.eclipse.persistence.services.weblogic.ClassSummaryDetail";
    
    /**
     * Construct a ClassSummaryDetail instance. The PropertyNames annotation is used 
     * to be able to construct a ClassSummaryDetail instance out of a CompositeData
     * instance. See MXBeans documentation for more details.
     */
    public ClassSummaryDetail(String className, String cacheType, String configuredSize,String currentSize , String parentClassName) {
        super(className, cacheType, configuredSize, currentSize , parentClassName);
        this.cacheType = cacheType;
        this.configuredSize = configuredSize;
        this.currentSize = currentSize;
        this.parentClassName = parentClassName;
    }
    
    private String className;
    private String cacheType;
    private String configuredSize;
    private String currentSize;
    private String parentClassName;
    
    // The corresponding CompositeType for this class
    private static CompositeType cType_= null;

    private static final String[] itemNames_= 
        {"Class Name", "Cache Type", "Configured Size",
         "Current Size","Parent Class Name"}; 

    static {
        try {
            OpenType[] itemTypes = {
                    SimpleType.STRING,
                    SimpleType.STRING,
                    SimpleType.STRING,
                    SimpleType.STRING,
                    SimpleType.STRING};
            cType_ = new CompositeType("org.eclipse.persistence.services.weblogic",
                                       // this should be a localized description
                                       // but isn't really required since the attribute
                                       // or parameter description should suffice
                                       // however this value cannot be null or empty
                                       "org.eclipse.persistence.services.weblogic.ClassSummaryDetail",
                                       itemNames_,
                                       // this should be a localized description
                                       // but isn't really required since the attribute
                                       // or parameter description should suffice
                                       // however this value cannot be null or empty
                                       itemNames_,
                                       itemTypes);
        }  catch(OpenDataException ode) {
            // this won't happen, but in case it does we should log
            throw new RuntimeException(ode);
        }
    }

    /**
     * Returns the CompositeType that describes this model
     * specific class
     */
    public static CompositeType toCompositeType() {
        return cType_;
    } 
    
    /**
     * Convert an instance of this model specific type to 
     * a CompositeData. This ensure that clients that do not
     * have access to the model specific class can still
     * use the MBean. The MXBean framework can perform this
     * conversion automatically.  
     * 
     * @param ct - This parameter is for JDK 1.6 compatibility reasons
     */
    public CompositeData toCompositeData(CompositeType ct) {
        Object[] itemValues = {
                this.className,
                this.cacheType,
                this.configuredSize,
                this.currentSize,
                this.parentClassName};

        CompositeData cData= null;
        try {
            cData= new CompositeDataSupport(cType_, itemNames_, itemValues);
        } catch( OpenDataException ode) {
            // this won't happen, but in case it does we should log
            throw new RuntimeException(ode);
        }
        return cData;
    }
    
    /**
     * Create an instance of the model specific class out of
     * an associated CompositeData instance
     */
    public static ClassSummaryDetail from(CompositeData cd) {   
        if (cd==null) { 
            return null;
        }

        return new ClassSummaryDetail( 
                (String)cd.get("Class Name"),
                (String)cd.get("Cache Type"),
                (String)cd.get("Current Size"),
                (String)cd.get("Parent Class Name"),
                (String)cd.get("Configured Size")
                );
    }

    public String getClassName() {
        return className;
    }

    public String getCacheType() {
        return cacheType;
    }

    public String getConfiguredSize() {
        return configuredSize;
    }

    public String getCurrentSize() {
        return currentSize;
    }

    public String getParentClassName() {
        return parentClassName;
    }
    
    public void setClassName(String className) {
        this.className = className;
    }
    
    public void setCacheType(String cacheType) {
        this.cacheType = cacheType;
    }

    public void setConfiguredSize(String configuredSize) {
        this.configuredSize = configuredSize;
    }

    public void setCurrentSize(String currentSize) {
        this.currentSize = currentSize;
    }

    public void setParentClassName(String parentClassName) {
        this.parentClassName = parentClassName;
    }
}




 */
public class WebLogicRuntimeServices extends RuntimeServices {

    /** This is the profile weight at server startup time. This is read-only */
    private int deployedSessionProfileWeight;

    /** This contains the session log from server startup time. This is read-only. */
    private SessionLog deployedSessionLog;

    public String objectName;

    private static final String EclipseLink_Product_Name = "EclipseLink";
    
    /**
     * PUBLIC:
     *  Default Constructor

     *  Create an instance of WebLogicRuntimeServices to be associated with the provided session
     *
     *  @param session The session to be used with these RuntimeServices
     *  @param String myBaseObjectName: "weblogic:....." (The JMX object name before it's wrapped in a ObjectName)
     */
    public WebLogicRuntimeServices(AbstractSession session) {
        super();

        this.updateDeploymentTimeData();
    }

    /**
     *  INTERNAL:
     *  Define the deployment time data associated with logging and profiling
     *
     */
    protected void updateDeploymentTimeData() {
        this.deployedSessionLog = (SessionLog)((AbstractSessionLog)session.getSessionLog()).clone();
        if (session.getProfiler() == null) {
            this.deployedSessionProfileWeight = -1;//there is no profiler
        } else {
            this.deployedSessionProfileWeight = session.getProfiler().getProfileWeight();
        }
    }

    /**
     * Answer the name of the EclipseLink session this MBean represents.

     * PUBLIC: Answer the EclipseLink log level at deployment time. This is read-only.
     */
    public String getDeployedEclipseLinkLogLevel() {
        return getNameForLogLevel(getDeployedSessionLog().getLevel());
    }

    /**

    }

    /**
    *        This method is used to get the type of profiling.
    *   Possible values are: "EclipseLink" or "None".
    */
    public synchronized String getProfilingType() {
        if (getUsesEclipseLinkProfiling().booleanValue()) {
            return EclipseLink_Product_Name;
        } else {
            return "None";
        }
    }

    /**
    *        This method is used to select the type of profiling.
    *   Valid values are: "EclipseLink" or "None". These values are not case sensitive.
    *   null is considered  to be "None".
    */
    public synchronized void setProfilingType(String profileType) {
        if ((profileType == null) || (profileType.compareToIgnoreCase("None") == 0)) {
            this.setUseNoProfiling();
        } else if (profileType.compareToIgnoreCase(EclipseLink_Product_Name) == 0) {
            this.setUseEclipseLinkProfiling();
        }
    }

    /**
    *        This method is used to turn on EclipseLink Performance Profiling
    */
    public void setUseEclipseLinkProfiling() {
        if (getUsesEclipseLinkProfiling().booleanValue()) {
            return;
        }
        getSession().setProfiler(new PerformanceProfiler());
    }

    /**
    *        This method answers true if EclipseLink Performance Profiling is on.
    */
    public Boolean getUsesEclipseLinkProfiling() {
        return Boolean.valueOf(getSession().getProfiler() instanceof PerformanceProfiler);
    }

    /**
    *        This method is used to turn off all Performance Profiling, DMS or EclipseLink.
    */
    public void setUseNoProfiling() {
        getSession().setProfiler(null);
    }

    /**
     *     Method returns if all Parameters should be bound or not
     */
    public Boolean getShouldBindAllParameters() {

    }

    /**
    *        This method will log the instance level locks in all Identity Maps in the session.
    */
    public void printIdentityMapLocks() {
        getSession().getIdentityMapAccessorInstance().getIdentityMapManager().printLocks();
    }

    /**
    *        This method will log the instance level locks in the Identity Map for the given class in the session.
    */
    public void printIdentityMapLocks(String registeredClassName) {
        Class registeredClass = (Class)getSession().getDatasourcePlatform().getConversionManager()
            .convertObject(registeredClassName, ClassConstants.CLASS);
        getSession().getIdentityMapAccessorInstance().getIdentityMapManager().printLocks(registeredClass);
    }

    /**
    *        This method assumes EclipseLink Profiling (as opposed to Java profiling).
    *        This will log at the INFO level a summary of all elements in the profile.
    */
    public void printProfileSummary() {
        if (!this.getUsesEclipseLinkProfiling().booleanValue()) {
            return;
        }
        PerformanceProfiler performanceProfiler = (PerformanceProfiler)getSession().getProfiler();
        getSession().getSessionLog().info(performanceProfiler.buildProfileSummary().toString());
    }

    /**
     * INTERNAL:
     * utility method to get rid of leading and trailing {}'s
     */
    private String trimProfileString(String originalProfileString) {
        String trimmedString;

        if (originalProfileString.length() > 1) {
            trimmedString = originalProfileString.substring(0, originalProfileString.length());
            if ((trimmedString.charAt(0) == '{') && (trimmedString.charAt(trimmedString.length() - 1) == '}')) {
                trimmedString = trimmedString.substring(1, trimmedString.length() - 1);
            }
            return trimmedString;
        } else {
            return originalProfileString;
        }
    }

    /**
    *        This method assumes EclipseLink Profiling (as opposed to Java profiling).
    *        This will log at the INFO level a summary of all elements in the profile, categorized
    *        by Class.
    */
    public void printProfileSummaryByClass() {
        if (!this.getUsesEclipseLinkProfiling().booleanValue()) {
            return;
        }
        PerformanceProfiler performanceProfiler = (PerformanceProfiler)getSession().getProfiler();
        //trim the { and } from the beginning at end, because they cause problems for the logger
        getSession().getSessionLog().info(trimProfileString(performanceProfiler.buildProfileSummaryByClass().toString()));
    }

    /**
    *        This method assumes EclipseLink Profiling (as opposed to Java profiling).
    *        This will log at the INFO level a summary of all elements in the profile, categorized
    *        by Query.
    */
    public void printProfileSummaryByQuery() {
        if (!this.getUsesEclipseLinkProfiling().booleanValue()) {
            return;
        }
        PerformanceProfiler performanceProfiler = (PerformanceProfiler)getSession().getProfiler();
        getSession().getSessionLog().info(trimProfileString(performanceProfiler.buildProfileSummaryByQuery().toString()));
    }

    /**
    * Return the log type, either "EclipseLink",  "Java" or the simple name of the logging class used.  
    *
    * @return the log type

    }

    /**
    *    This method is used to initialize the identity maps specified by className.
    * @param className the fully qualified classnames identifying the identity map to initialize
    */
    public synchronized void initializeIdentityMap(String className) throws ClassNotFoundException {
        Class registeredClass;

        //get identity map, and initialize
        registeredClass = (Class)getSession().getDatasourcePlatform().getConversionManager()
            .convertObject(className, ClassConstants.CLASS);
        getSession().getIdentityMapAccessor().initializeIdentityMap(registeredClass);
        ((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_identity_map_initialized", className);
    }

    /**
    *    This method is used to invalidate the identity maps in the session.
    */
    public synchronized void invalidateAllIdentityMaps() {




/*******************************************************************************
 * Copyright (c) 1998, 2010 Oracle. All rights reserved.
 * This program and the accompanying materials are made available under the 
 * terms of the Eclipse Public License v1.0 and Eclipse Distribution License v. 1.0 
 * which accompanies this distribution. 
 * The Eclipse Public License is available at http://www.eclipse.org/legal/epl-v10.html
 * and the Eclipse Distribution License is available at 
 * http://www.eclipse.org/org/documents/edl-v10.php.
 *
 * Contributors:
 *     @author  mobrien
 *     @since   EclipseLink 2.2 enh# 316511
 *     06/22/2010-2.2 Michael O'Brien 
 *       - 316511: Add JBoss specific JMX MBean attributes and functions
 *       see <link>http://wiki.eclipse.org/EclipseLink/DesignDocs/316513</link>
 ******************************************************************************/  
package org.eclipse.persistence.services.websphere;

import org.eclipse.persistence.services.ClassSummaryDetailBase;

/**
 * The class is used internally by the Portable JMX Framework to convert 
 * model specific classes into Open Types so that the attributes of model class can
 * be exposed by MBeans.
 */
public class ClassSummaryDetail extends ClassSummaryDetailBase {

    public static final String COMPOSITE_TYPE_TYPENAME = "org.eclipse.persistence.services.websphere";
    public static final String COMPOSITE_TYPE_DESCRIPTION = "org.eclipse.persistence.services.websphere.ClassSummaryDetail";

    /**
     * Construct a ClassSummaryDetail instance. The PropertyNames annotation is used 
     * to be able to construct a ClassSummaryDetail instance out of a CompositeData
     * instance. See MXBeans documentation for more details.
     */
    public ClassSummaryDetail(String className, String cacheType, String configuredSize,String currentSize , String parentClassName) {
        super(className, cacheType, configuredSize, currentSize , parentClassName);
    }
}




/*******************************************************************************
 * Copyright (c) 1998, 2010 Oracle. All rights reserved.
 * This program and the accompanying materials are made available under the 
 * terms of the Eclipse Public License v1.0 and Eclipse Distribution License v. 1.0 
 * which accompanies this distribution. 
 * The Eclipse Public License is available at http://www.eclipse.org/legal/epl-v10.html
 * and the Eclipse Distribution License is available at 
 * http://www.eclipse.org/org/documents/edl-v10.php.
 *
 * Contributors:
 *     @author  mobrien
 *     @since   EclipseLink 2.2 enh# 316511
 *     06/22/2010-2.2 Michael O'Brien 
 *       - 316511: Add JBoss specific JMX MBean attributes and functions
 *       see <link>http://wiki.eclipse.org/EclipseLink/DesignDocs/316513</link>
 ******************************************************************************/  
package org.eclipse.persistence.services.websphere;

import org.eclipse.persistence.internal.sessions.AbstractSession;
import org.eclipse.persistence.sessions.Session;

/**
 * <p>
 * <b>Purpose</b>: Provide a dynamic interface into the EclipseLink Session.
 * <p>
 * <b>Description</b>: This class is meant to provide a framework for gaining access to configuration
 * of the EclipseLink Session during runtime.  It will provide the basis for development
 * of a JMX service and possibly other frameworks.
 */
public class MBeanWebSphereRuntimeServices extends WebSphereRuntimeServices implements MBeanWebSphereRuntimeServicesMBean {
    public MBeanWebSphereRuntimeServices(Session session) {
        super((AbstractSession)session);
    }
}




/*******************************************************************************
 * Copyright (c) 1998, 2010 Oracle. All rights reserved.
 * This program and the accompanying materials are made available under the 
 * terms of the Eclipse Public License v1.0 and Eclipse Distribution License v. 1.0 
 * which accompanies this distribution. 
 * The Eclipse Public License is available at http://www.eclipse.org/legal/epl-v10.html
 * and the Eclipse Distribution License is available at 
 * http://www.eclipse.org/org/documents/edl-v10.php.
 *
 * Contributors:
 *     @author  mobrien
 *     @since   EclipseLink 2.2 enh# 316511
 *     06/22/2010-2.2 Michael O'Brien 
 *       - 316511: Add JBoss specific JMX MBean attributes and functions
 *       see <link>http://wiki.eclipse.org/EclipseLink/DesignDocs/316513</link>
 ******************************************************************************/  
package org.eclipse.persistence.services.websphere;

import java.util.ArrayList;
import java.util.Vector;

import org.eclipse.persistence.services.mbean.MBeanRuntimeServicesMBean;

/**
 * <p>
 * <b>Purpose</b>: Provide a dynamic interface into the EclipseLink Session.
 * <p>
 * <b>Description</b>: This class is meant to provide facilities for managing an EclipseLink session external
 * to EclipseLink over JMX.
 */
public interface MBeanWebSphereRuntimeServicesMBean extends MBeanRuntimeServicesMBean {
    /**
     *  Answer the name of the EclipseLink session this MBean represents.
     */
    public String getSessionName();

    /**
     *  Answer the type of the EclipseLink session this MBean represents.
     * Types include: "ServerSession", "DatabaseSession", "SessionBroker"
     */
    public String getSessionType();

    /**
     *  Provide an instance of 2 Dimensional Array simulating tabular format information about all
     * classes in the session whose class names match the provided filter.
     *
     * The 2 Dimensional array contains each item with values being row object array. Each row object array 
     * represents EclipseLink class details info with respect to below attributes:  
     * ["Class Name", "Parent Class Name",  "Cache Type", "Configured Size", "Current Size"]
     *
     */
    public Object[][] getClassSummaryDetailsUsingFilter(String filter);
    
    /**
     *  Provide an instance of 2 Dimensional Array simulating tabular format information about all
     * classes in the session.
     *
     * The 2 Dimensional array contains each item with values being row object array. Each row object array 
     * represents EclipseLink class details info with respect to below attributes:  
     * ["Class Name", "Parent Class Name",  "Cache Type", "Configured Size", "Current Size"]
     *
     */
    public Object[][] getClassSummaryDetails();
    
    /**
     *  Provide a list of instance of ClassSummaryDetail containing information about the
     * classes in the session whose class names match the provided filter.
     *
     * ClassSummaryDetail is a model specific class that can be used internally by the Portable JMX Framework to
     * convert class attribute to JMX required open type, it has:-
     *    1. model specific type that needs to be converted : ["Class Name", "Parent Class Name",  "Cache Type", "Configured Size", "Current Size"]
     *    2. convert methods.  
     *
     * @param filter A comma separated list of strings to match against.
     * @return A ArrayList of instance of ClassSummaryDetail containing class information for the class names that match the filter.
     */
    public ArrayList <ClassSummaryDetail>  getClassSummaryDetailsUsingFilterArray(String filter);
    
    /**
     *  Provide a list of instance of ClassSummaryDetail containing information about all
     * classes in the session.
     *
     * ClassSummaryDetail is a model specific class that can be used internally by the Portable JMX Framework to
     * convert class attribute to JMX required open type, it has:-
     *    1. model specific type that needs to be converted : ["Class Name", "Parent Class Name",  "Cache Type", "Configured Size", "Current Size"]
     *    2. convert methods.  
     *
     * @return A ArrayList of instance of ClassSummaryDetail containing class information for the class names that match the filter.
     */
    public ArrayList <ClassSummaryDetail>  getClassSummaryDetailsArray();

    /**
    *  INTERNAL:
    *  This method traverses the EclipseLink descriptors and returns a Vector of the descriptor's
    *   reference class names that match the provided filter. The filter is a comma separated
    *   list of strings to match against.
    *
    *   @param filter A comma separated list of strings to match against.
    *   @return A Vector of class names that match the filter.
    */
    public Vector getMappedClassNamesUsingFilter(String filter);

    /**
     * getModuleName(): Answer the name of the context-root of the application that this session is associated with.
     * Answer "unknown" if there is no module name available.
     * Default behavior is to return "unknown"
     */
    public String getModuleName();
    
    /**
     * getApplicationName(): Answer the name of the module (EAR name) that this session is associated with.
     * Answer "unknown" if there is no application name available.
     * Default behavior is to return "unknown"
     */
    public String getApplicationName();

    /**
     *  Answer the EclipseLink log level at deployment time. This is read-only.
     */
    public String getDeployedEclipseLinkLogLevel();

    /**
     *  Answer the EclipseLink log level that is changeable.
     * This does not affect the log level in the project (i.e. The next
     * time the application is deployed, changes are forgotten)
     */
    public String getCurrentEclipseLinkLogLevel();

    /**
     *  Set the EclipseLink log level to be used at runtime.
     *
     * This does not affect the log level in the project (i.e. The next
     * time the application is deployed, changes are forgotten)
     *
     * @param String newLevel: new log level
     */
    public  void setCurrentEclipseLinkLogLevel(String newLevel);

    /**
    *        This method is used to get the type of profiling.
    *   Possible values are: "EclipseLink" or "None".
    */
    public  String getProfilingType();

    /**
    *        This method is used to select the type of profiling.
    *   Valid values are: "EclipseLink" or "None". These values are not case sensitive.
    *   null is considered  to be "None".
    */
    public  void setProfilingType(String profileType);

    /**
    *        This method is used to turn on EclipseLink Performance Profiling
    */
    public void setUseEclipseLinkProfiling();

    /**
    *        This method answers true if EclipseLink Performance Profiling is on.
    */
    public Boolean getUsesEclipseLinkProfiling();

    /**
    *        This method is used to turn off all Performance Profiling, DMS or EclipseLink.
    */
    public void setUseNoProfiling();

    /**
      *     Return the size of strings after which will be bound into the statement
      *     If we are not using a DatabaseLogin, or we're not using string binding,
      *     answer 0 (zero).
      */
    public Integer getStringBindingSize();

    /**
      *        This method will return a long indicating the exact time in Milliseconds that the
      *   session connected to the database.
      */
    public Long getTimeConnectionEstablished();

    /**
      *        This method will return if batchWriting is in use or not.
      */
    public Boolean getUsesJDBCBatchWriting();

    /**
      *     Shows if Byte Array Binding is turned on or not
      */
    public Boolean getUsesByteArrayBinding();

    /**
      *     Shows if native SQL is being used
      */
    public Boolean getUsesNativeSQL();

    /**
      *     This method indicates if streams are being used for binding
      */
    public Boolean getUsesStreamsForBinding();

    /**
      *     This method indicates if Strings are being bound
      */
    public Boolean getUsesStringBinding();

    /**
    *     Used to clear the statement cache. Only valid if statements are being cached
    */
    public  void clearStatementCache();

    /**
    *     This method will print the available Connection pools to the SessionLog.
    * @return void
    */
    public void printAvailableConnectionPools();

    /**
    *     This method will retrieve the max size of a particular connection pool
    * @param poolName the name of the pool to get the max size for
    * @return Integer for the max size of the pool. Return -1 if pool doesn't exist.
    */
    public Integer getMaxSizeForPool(String poolName);

    /**
    *     This method will retrieve the min size of a particular connection pool
    * @param poolName the name of the pool to get the min size for
    * @return Integer for the min size of the pool. Return -1 if pool doesn't exist.
    */
    public Integer getMinSizeForPool(String poolName);

    /**
    *        This method is used to output those Class Names that have identity Maps in the Session.
    * Please note that SubClasses and aggregates will be missing form this list as they do not have
    * separate identity maps.
    * @return void
    */
    public void printClassesInSession();

    /**
    *        This method will log the objects in the Identity Map.
    * There is no particular order to these objects.
    * @param className the fully qualified classname identifying the identity map
    * @exception  thrown then the IdentityMap for that class name could not be found
    */
    public void printObjectsInIdentityMap(String className) throws ClassNotFoundException;

    /**
    *        This method will log the types of Identity Maps in the session.
    */
    public void printAllIdentityMapTypes();

    /**
    *        This method will log all objects in all Identity Maps in the session.
    */
    public void printObjectsInIdentityMaps();

    /**
    *        This method will SUM and return the number of objects in all Identity Maps in the session.
    */
    public Integer getNumberOfObjectsInAllIdentityMaps();

    /**
    *        This method will answer the number of persistent classes contained in the session.
    *   This does not include aggregates.
    */
    public Integer getNumberOfPersistentClasses();

    /**
    *        This method will log the instance level locks in all Identity Maps in the session.
    */
    public void printIdentityMapLocks();

    /**
    *        This method will log the instance level locks in the Identity Map for the given class in the session.
    */
    public void printIdentityMapLocks(String registeredClassName);

    /**
    *        This method assumes EclipseLink Profiling (as opposed to Java profiling).
    *        This will log at the INFO level a summary of all elements in the profile.
    */
    public void printProfileSummary();

    /**
    *        This method assumes EclipseLink Profiling (as opposed to Java profiling).
    *        This will log at the INFO level a summary of all elements in the profile, categorized
    *        by Class.
    */
    public void printProfileSummaryByClass();

    /**
    *        This method assumes EclipseLink Profiling (as opposed to Java profiling).
    *        This will log at the INFO level a summary of all elements in the profile, categorized
    *        by Query.
    */
    public void printProfileSummaryByQuery();

    /**
    * Return the log type, either "EclipseLink",  "Java" or the simple name of the logging class used.  
    * @return the log type
    */
    public String getLogType();

    /**
    * Return the database platform used by the DatabaseSession.
    * @return String databasePlatform
    */
    public String getDatabasePlatform();

    /**
    * Return JDBCConnection detail information. This includes URL and datasource information.
    */
    public  String getJdbcConnectionDetails();

    /**
    * Return connection pool type. Values include: "Internal", "External" and "N/A".
    */
    public  String getConnectionPoolType();

    /**
    * Return db driver class name. This only applies to DefaultConnector. Return "N/A" otherwise.
    */
    public  String getDriver();

    /**
    * Return the log filename. This returns the fully qualified path of the log file when
    * EclipseLink logging is enabled. Null is returned otherwise.
    *
    * @return String logFilename
    */
    public String getLogFilename();

    /**
    *    This method is used to initialize the identity maps in the session.
    */
    public void initializeAllIdentityMaps();

    /**
    *    This method is used to initialize the identity maps specified by the Vector of classNames.
    *
    * @param classNames String[] of fully qualified classnames identifying the identity maps to initialize
    */
    public void initializeIdentityMaps(String[] classNames) throws ClassNotFoundException;

    /**
    *    This method is used to initialize the identity maps specified by className.
    * @param className the fully qualified classnames identifying the identity map to initialize
    */
    public void initializeIdentityMap(String className) throws ClassNotFoundException;

    /**
    *    This method is used to invalidate the identity maps in the session.
    */
    public void invalidateAllIdentityMaps();

    /**
    *    This method is used to invalidate the identity maps specified by the String[] of classNames.
    * @param classNames String[] of fully qualified classnames identifying the identity maps to invalidate
    * @param recurse    Boolean indicating if we want to invalidate the children identity maps too
    */
    public void invalidateIdentityMaps(String[] classNamesParam, Boolean recurse) throws ClassNotFoundException;

    /**
    *    This method is used to invalidate the identity maps specified by className. This does not
    * invalidate the children identity maps
    * @param className the fully qualified classname identifying the identity map to invalidate
    */
    public void invalidateIdentityMap(String className) throws ClassNotFoundException;

    /**
    *    This method is used to invalidate the identity maps specified by className.
    * @param className the fully qualified classname identifying the identity map to invalidate
    * @param recurse    Boolean indicating if we want to invalidate the children identity maps too
    */
    public void invalidateIdentityMap(String className, Boolean recurse) throws ClassNotFoundException;

    /**
     * Return whether this session is an EclipseLink JPA session.
     * The absence of this function or a value of false will signify that the session
     * belongs to a provider other than EclipseLink.  
     * @return
     */
    public boolean isJPASession();
    
}




/*******************************************************************************
 * Copyright (c) 1998, 2010 Oracle. All rights reserved.
 * This program and the accompanying materials are made available under the 
 * terms of the Eclipse Public License v1.0 and Eclipse Distribution License v. 1.0 
 * which accompanies this distribution. 
 * The Eclipse Public License is available at http://www.eclipse.org/legal/epl-v10.html
 * and the Eclipse Distribution License is available at 
 * http://www.eclipse.org/org/documents/edl-v10.php.
 *
 * Contributors:
 *     @author  mobrien
 *     @since   EclipseLink 2.2 enh# 316511
 *     06/22/2010-2.2 Michael O'Brien 
 *       - 316511: Add JBoss specific JMX MBean attributes and functions
 *       see <link>http://wiki.eclipse.org/EclipseLink/DesignDocs/316513</link>
 ******************************************************************************/  
package org.eclipse.persistence.services.websphere;

import java.util.ArrayList;
import java.util.Collections;
import java.util.Enumeration;
import java.util.HashMap;
import java.util.Hashtable;
import java.util.Iterator;
import java.util.Locale;
import java.util.Map;
import java.util.StringTokenizer;
import java.util.Vector;
import java.util.regex.PatternSyntaxException;

import javax.management.openmbean.CompositeData;
import javax.management.openmbean.CompositeDataSupport;
import javax.management.openmbean.CompositeType;
import javax.management.openmbean.OpenDataException;
import javax.management.openmbean.OpenType;
import javax.management.openmbean.SimpleType;
import javax.management.openmbean.TabularData;
import javax.management.openmbean.TabularDataSupport;
import javax.management.openmbean.TabularType;


import org.eclipse.persistence.descriptors.ClassDescriptor;
import org.eclipse.persistence.internal.databaseaccess.DatabaseAccessor;
import org.eclipse.persistence.internal.databaseaccess.DatasourcePlatform;
import org.eclipse.persistence.internal.helper.ClassConstants;
import org.eclipse.persistence.internal.helper.Helper;
import org.eclipse.persistence.internal.identitymaps.CacheIdentityMap;
import org.eclipse.persistence.internal.identitymaps.CacheKey;
import org.eclipse.persistence.internal.identitymaps.FullIdentityMap;
import org.eclipse.persistence.internal.identitymaps.HardCacheWeakIdentityMap;
import org.eclipse.persistence.internal.identitymaps.IdentityMap;
import org.eclipse.persistence.internal.identitymaps.NoIdentityMap;
import org.eclipse.persistence.internal.identitymaps.SoftCacheWeakIdentityMap;
import org.eclipse.persistence.internal.identitymaps.SoftIdentityMap;
import org.eclipse.persistence.internal.identitymaps.WeakIdentityMap;
import org.eclipse.persistence.internal.sessions.AbstractSession;
import org.eclipse.persistence.internal.sessions.DatabaseSessionImpl;
import org.eclipse.persistence.logging.AbstractSessionLog;
import org.eclipse.persistence.logging.DefaultSessionLog;
import org.eclipse.persistence.logging.JavaLog;
import org.eclipse.persistence.logging.SessionLog;
import org.eclipse.persistence.platform.server.was.WebSphere_7_Platform;
import org.eclipse.persistence.services.RuntimeServices;
import org.eclipse.persistence.sessions.DatabaseLogin;
import org.eclipse.persistence.sessions.DefaultConnector;
import org.eclipse.persistence.sessions.server.ConnectionPool;
import org.eclipse.persistence.sessions.server.ServerSession;
import org.eclipse.persistence.tools.profiler.PerformanceProfiler;

/**
 * <p>
 * <b>Purpose</b>: Provide a dynamic interface into the EclipseLink Session.
 * <p>
 * <b>Description</b>: This class is meant to provide facilities for managing an EclipseLink session external
 * to EclipseLink over JMX.
 */
public class WebSphereRuntimeServices extends RuntimeServices {

    /**
     * PUBLIC:
     *  Default Constructor
     */
    public WebSphereRuntimeServices() {
        super();
    }

    /**
     *  PUBLIC:
     *  Create an instance of WebSphereRuntimeServices to be associated with the provided session
     *
     *  @param session The session to be used with these RuntimeServices
     */
    public WebSphereRuntimeServices(AbstractSession session) {
        super();
        this.session = session;
        this.updateDeploymentTimeData();
    }

    /**
     *  Create an instance of WebSphereRuntimeServices to be associated with the provided locale
     *
     *  The user must call setSession(Session) afterwards to define the session.
     */
    public WebSphereRuntimeServices(Locale locale) {
    }

    /**
     *  INTERNAL:
     *  Define the session that this instance is providing runtime services for
     *
     *  @param Session session The session to be used with these RuntimeServices
     */
    protected void setSession(AbstractSession newSession) {
        this.session = newSession;
        this.updateDeploymentTimeData();
    }

    /**
     * Answer the name of the EclipseLink session this MBean represents.
     */
    public String getSessionName() {
        return getSession().getName();
    }

    /**
     * Answer the type of the EclipseLink session this MBean represents.
     * Types include: "ServerSession", "DatabaseSession", "SessionBroker"
     */
    public String getSessionType() {
        return Helper.getShortClassName(getSession().getClass());
    }

    /**
     * Provide an instance of 2 Dimensional Array simulating tabular format information about all
     * classes in the session whose class names match the provided filter.
     *
     * The 2 Dimensional array contains each item with values being row object array. Each row object array 
     * represents EclipseLink class details info with respect to below attributes:  
     * ["Class Name", "Parent Class Name",  "Cache Type", "Configured Size", "Current Size"]
     *
     */
    public Object[][] getClassSummaryDetailsUsingFilter(String filter){
        try{
           return  tabularDataTo2DArray(buildClassSummaryDetailsUsingFilter(filter),new String[] {
               "Class Name", "Parent Class Name", "Cache Type", "Configured Size", "Current Size" });
        } catch (Exception exception) {
           AbstractSessionLog.getLog().log(SessionLog.SEVERE, "weblogic_mbean_runtime_exception", exception); 
        }
        return null;
    }
    
    /**
     * Provide a list of instance of ClassSummaryDetail containing information about the
     * classes in the session whose class names match the provided filter.
     *
     * ClassSummaryDetail is a model specific class that can be used internally by the Portable JMX Framework to
     * convert class attribute to JMX required open type, it has:-
     *    1. model specific type that needs to be converted : ["Class Name", "Parent Class Name",  "Cache Type", "Configured Size", "Current Size"]
     *    2. convert methods.  
     *
     * @param filter A comma separated list of strings to match against.
     * @return A ArrayList of instance of ClassSummaryDetail containing class information for the class names that match the filter.
     */
    public ArrayList <ClassSummaryDetail>  getClassSummaryDetailsUsingFilterArray(String filter) {
        // if the filter is null, return all the details
        if (filter == null) {
            return getClassSummaryDetailsArray();
        }

        try {
            Vector mappedClassNames = getMappedClassNamesUsingFilter(filter);
            String mappedClassName;
            ArrayList classSummaryDetails = new ArrayList<ClassSummaryDetail>();
            // Check if there aren't any classes mapped
            if (mappedClassNames.size() == 0) {
                return null;
            }

            // get details for each class, and add the details to the summary
            for (int index = 0; index < mappedClassNames.size(); index++) {
                mappedClassName = (String)mappedClassNames.elementAt(index);
                classSummaryDetails.add(buildLowlevelDetailsFor(mappedClassName));
            }
            return classSummaryDetails;
        } catch (Exception openTypeException) {
            AbstractSessionLog.getLog().log(SessionLog.SEVERE, "weblogic_mbean_runtime_exception", openTypeException);            
            openTypeException.printStackTrace();
        }

        // wait to get requirements from EM
        return null;
    }

    /**
     * Provide a list of instance of ClassSummaryDetail containing information about all
     * classes in the session.
     *
     * ClassSummaryDetail is a model specific class that can be used internally by the Portable JMX Framework to
     * convert class attribute to JMX required open type, it has:-
     *    1. model specific type that needs to be converted : ["Class Name", "Parent Class Name",  "Cache Type", "Configured Size", "Current Size"]
     *    2. convert methods.  
     *
     * @return A ArrayList of instance of ClassSummaryDetail containing class information for the class names that match the filter.
     */
    public ArrayList <ClassSummaryDetail> getClassSummaryDetailsArray() {
        try {            
            Vector mappedClassNames = getMappedClassNames();
            ArrayList classSummaryDetails = new ArrayList<ClassSummaryDetail>();            
            // Check if there aren't any classes mapped
            if (mappedClassNames.size() == 0) {
                return null;
            }

            // get details for each class, and add the details to the summary
            for (int index = 0; index < mappedClassNames.size(); index++) {
                String mappedClassName = (String)mappedClassNames.elementAt(index);
                classSummaryDetails.add(buildLowlevelDetailsFor(mappedClassName));
            }

            return classSummaryDetails;
        } catch (Exception openTypeException) {
            AbstractSessionLog.getLog().log(SessionLog.SEVERE, "weblogic_mbean_runtime_exception", openTypeException);
            openTypeException.printStackTrace();
        }

        // wait to get requirements from EM
        return null;
    }
    
    /**
     * PUBLIC: Provide an instance of 2 Dimensional Array simulating tabular format information about all
     * classes in the session.
     *
     * The 2 Dimensional array contains each item with values being row object array. Each row object array 
     * represents EclipseLink class details info with respect to below attributes:  
     * ["Class Name", "Parent Class Name",  "Cache Type", "Configured Size", "Current Size"]
     *
     */
    public Object[][] getClassSummaryDetails() {
        try{
           return tabularDataTo2DArray(buildClassSummaryDetails(),new String[] {
               "Class Name", "Parent Class Name", "Cache Type", "Configured Size", "Current Size" });
        } catch (Exception exception){
           AbstractSessionLog.getLog().log(SessionLog.SEVERE, "weblogic_mbean_runtime_exception", exception);
        }
        return null;
    }
    
    /**
     * INTERNAL:
     * Provide an instance of TabularData containing information about the
     * classes in the session whose class names match the provided filter.
     *
     * The TabularData contains rowData with values being CompositeData(s)
     *
     * CompositeData has:
     *    CompositeType: column names are ["Class Name", "Parent Class Name",  "Cache Type", "Configured Size", "Current Size"]
     *
     *  Each CompositeData can have get(myColumnName) sent to it.
     *
     *
     * @param filter A comma separated list of strings to match against.
     * @return A TabularData of information for the class names that match the filter.
     */
    private TabularData buildClassSummaryDetailsUsingFilter(String filter) {
        // if the filter is null, return all the details
        if (filter == null) {
            return buildClassSummaryDetails();
        }

        try {
            Vector mappedClassNames = getMappedClassNamesUsingFilter(filter);
            String mappedClassName;
            TabularDataSupport rowData = new TabularDataSupport(buildTabularTypeForClassSummaryDetails());
            // Check if there aren't any classes mapped
            if (mappedClassNames.size() == 0) {
                return null;
            }

            // get details for each class, and add the details to the summary
            for (int index = 0; index < mappedClassNames.size(); index++) {
                mappedClassName = (String)mappedClassNames.elementAt(index);
                String[] key = new String[] { mappedClassName };
                rowData.put(key, buildDetailsFor(mappedClassName, rowData.getTabularType().getRowType()));
            }
            return rowData;
        } catch (Exception exception) {
            AbstractSessionLog.getLog().log(SessionLog.SEVERE, "weblogic_mbean_runtime_exception", exception);
        }

        // wait to get requirements from EM
        return null;
    }

    /**
     * INTERNAL: 
     * Provide an instance of TabularData containing information about all
     * classes in the session.
     *
     * The TabularData contains rowData with values being CompositeData(s)
     *
     * CompositeData has:
     *    CompositeType: column names are ["Class Name", "Parent Class Name",  "Cache Type", "Configured Size", "Current Size"]
     *
     *  Each CompositeData can have get(myColumnName) sent to it.
     *
     */
    private TabularData buildClassSummaryDetails() {
        try {
            Vector mappedClassNames = getMappedClassNames();
            String mappedClassName;
            TabularDataSupport rowData = new TabularDataSupport(buildTabularTypeForClassSummaryDetails());
            // Check if there aren't any classes mapped
            if (mappedClassNames.size() == 0) {
                return null;
            }

            // get details for each class, and add the details to the summary
            for (int index = 0; index < mappedClassNames.size(); index++) {
                mappedClassName = (String)mappedClassNames.elementAt(index);
                String[] key = new String[] { mappedClassName };
                rowData.put(key, buildDetailsFor(mappedClassName, rowData.getTabularType().getRowType()));
            }

            return rowData;
        } catch (Exception exception) {
            AbstractSessionLog.getLog().log(SessionLog.SEVERE, "weblogic_mbean_runtime_exception", exception);
        }

        // wait to get requirements from EM
        return null;
    }

    /**
     * INTERNAL:
     * Answer the fully qualified names of the classes mapped in the session.
     * This uses the mappedClass from the CMPPolicy.
     *
     * @return java.util.Vector
     */
    
    private Vector getMappedClassNames() {
        Hashtable alreadyAdded = new Hashtable();
        Vector mappedClassNames = new Vector();
        String mappedClassName = null;

        Iterator descriptorsIterator = getSession().getProject().getDescriptors()
                .values().iterator();
        while (descriptorsIterator.hasNext()) {
            ClassDescriptor nextDescriptor = (ClassDescriptor) descriptorsIterator.next();

            // differentiate between a generated class and not, by comparing the descriptor's Java class
            if (nextDescriptor.getCMPPolicy() != null) {
                if (nextDescriptor.getCMPPolicy().getMappedClass() != null) {
                    mappedClassName = nextDescriptor.getCMPPolicy().getMappedClass().getName();
                }
            }

            if (mappedClassName == null) {
                mappedClassName = nextDescriptor.getJavaClassName();
            }
            if (alreadyAdded.get(mappedClassName) == null) {
                alreadyAdded.put(mappedClassName, Boolean.TRUE);
                mappedClassNames.addElement(mappedClassName);
            }
            mappedClassName = null;
        }
        return mappedClassNames;
    }

    /**
    *  INTERNAL:
    *  This method traverses the EclipseLink descriptors and returns a Vector of the descriptor's
    *   reference class names that match the provided filter. The filter is a comma separated
    *   list of strings to match against.
    *
    *   @param filter A comma separated list of strings to match against.
    *   @return A Vector of class names that match the filter.
    */
    public Vector getMappedClassNamesUsingFilter(String filter) {
        //Output Vector
        Vector outputVector = new Vector();

        //Input mapped class names
        Vector mappedClassNames = getMappedClassNames();

        //Input filter values
        ArrayList filters = new ArrayList();
        StringTokenizer lineTokens = new StringTokenizer(filter, ",");
        while (lineTokens.hasMoreTokens()) {
            filters.add(lineTokens.nextToken());
        }
        for (int i = 0; i < mappedClassNames.size(); i++) {
            String className = (String)mappedClassNames.get(i);
            String classNameLowerCase = ((String)mappedClassNames.get(i)).toLowerCase();
            for (int j = 0; j < filters.size(); j++) {
                String filterValue = (Helper.rightTrimString((String)filters.get(j)).trim()).toLowerCase();
                if (filterValue.indexOf('*') == 0) {
                    filterValue = filterValue.substring(1);
                }
                try {
                    //Note: String.matches(String regex) since jdk1.4
                    if (classNameLowerCase.matches(new StringBuffer().append("^.*").append(filterValue).append(".*$").toString())) {
                        if (!outputVector.contains(className)) {
                            outputVector.add(className);
                        }
                    }
                } catch (PatternSyntaxException exception) {
                    //regular expression syntax error
                    AbstractSessionLog.getLog().log(SessionLog.FINEST, "pattern_syntax_error", exception);
                }
            }
        }
        Collections.sort(outputVector);
        return outputVector;
    }

    /**
     * INTERNAL:
     * Answer the TabularType describing the TabularData that we return from
     * getCacheSummaryDetails() and getCacheSummaryDetails(String filter)
     *
     * This is mostly for the client side to see what kind of information is returned.
     *
     * @return javax.management.openmbean.TabularType
     */
    private TabularType buildTabularTypeForClassSummaryDetails() throws OpenDataException {
        return new TabularType(getSessionName(), "Session description", buildCompositeTypeForClassSummaryDetails(),
                new String[] { "Class Name" });
    }

    /**
     * INTERNAL:
     * Answer the CompositeType describing the CompositeData that we return for
     * each IdentityMap (or subclass).
     *
     * This is mostly for the client side to see what kind of information is returned.
     * @return javax.management.openmbean.CompositeType
     */
    private CompositeType buildCompositeTypeForClassSummaryDetails() throws OpenDataException {
        return new CompositeType("Class Details", "Details of class for Class Summary", new String[] { 
                "Class Name", "Parent Class Name", "Cache Type", "Configured Size", "Current Size" }, new String[] { 
                "Class Name", "Parent Class Name", "Cache Type", "Configured Size", "Current Size" }, new OpenType[] { 
                SimpleType.STRING, SimpleType.STRING, SimpleType.STRING, SimpleType.STRING, SimpleType.STRING });
    }

    /**
     * INTERNAL:
     * Answer the CompositeData containing the cache details for the given mappedClassName
     * This uses a CompositeDataSupport, which implements CompositeData
     *
     * @param String mappedClassName: fullyQualified class name of the class
     * @param CompositeType detailsType: describes the format of the returned CompositeData

     * @return javax.management.openmbean.CompositeData
     */
    private CompositeData buildDetailsFor(String mappedClassName, CompositeType detailsType) throws Exception {
        return new CompositeDataSupport(detailsType, buildLowlevelDetailsFor(mappedClassName));
    }

    /**
     * INTERNAL:
     * Helper to build a HashMap to help in the construction of a CompositeData
     *
     * @param String mappedClassName: fullyQualified class name of the class

     * @return HashMap
     */
    private HashMap buildLowlevelDetailsFor(String mappedClassName) {
        Class mappedClass = (Class)getSession().getDatasourcePlatform().getConversionManager().convertObject(mappedClassName, ClassConstants.CLASS);
        IdentityMap identityMap = getSession().getIdentityMapAccessorInstance().getIdentityMap(mappedClass);
        ClassDescriptor descriptor = getSession().getProject().getDescriptor(mappedClass);

        String cacheType = getCacheTypeFor(identityMap.getClass());
        String configuredSize = "" + identityMap.getMaxSize();
        String currentSize = "";

        //show the current size, including subclasses 
        currentSize = "" + identityMap.getSize(mappedClass, true);

        String parentClassName = "";

        boolean isChildDescriptor = descriptor.isChildDescriptor();

        HashMap details = new HashMap();

        details.put("Class Name", mappedClassName);
        details.put("Cache Type", (isChildDescriptor ? "" : cacheType));
        details.put("Configured Size", (isChildDescriptor ? "" : configuredSize));
        details.put("Current Size", currentSize);
        //If I have a parent class name, get it. Otherwise, leave blank
        if (descriptor.hasInheritance()) {
            if (descriptor.getInheritancePolicy().getParentDescriptor() != null) {
                parentClassName = descriptor.getInheritancePolicy().getParentClassName();
            }
        }
        details.put("Parent Class Name", parentClassName);

        return details;
    }

    /**
     * INTERNAL:
     * Helper to build a HashMap to help in the construction of a CompositeData
     *
     * @param String mappedClassName: fullyQualified class name of the class

     * @return HashMap
     */
    private ClassSummaryDetail buildLowlevelDetailsForNew(String mappedClassName) {
        Class mappedClass = (Class)getSession().getDatasourcePlatform().getConversionManager().convertObject(mappedClassName, ClassConstants.CLASS);
        IdentityMap identityMap = getSession().getIdentityMapAccessorInstance().getIdentityMap(mappedClass);
        ClassDescriptor descriptor = getSession().getProject().getDescriptor(mappedClass);

        String cacheType = getCacheTypeFor(identityMap.getClass());
        String configuredSize = "" + identityMap.getMaxSize();
        String currentSize = "";

        //show the current size, including subclasses 
        currentSize = "" + identityMap.getSize(mappedClass, true);

        String parentClassName = "";

        boolean isChildDescriptor = descriptor.isChildDescriptor();

        ClassSummaryDetail details = new ClassSummaryDetail(
                mappedClassName,
                (isChildDescriptor ? "" : cacheType),
                (isChildDescriptor ? "" : configuredSize),
                currentSize,
                parentClassName);

        return details;
    }
    
    /**
     * INTERNAL:
     * getCacheTypeFor: Give a more UI-friendly version of the cache type
     */
    private String getCacheTypeFor(Class identityMapClass) {
        if (identityMapClass == CacheIdentityMap.class) {
            return "Cache";
        } else if (identityMapClass == FullIdentityMap.class) {
            return "Full";
        } else if (identityMapClass == HardCacheWeakIdentityMap.class) {
            return "HardWeak";
        } else if (identityMapClass == NoIdentityMap.class) {
            return "None";
        } else if (identityMapClass == SoftCacheWeakIdentityMap.class) {
            return "SoftWeak";
        } else if (identityMapClass == WeakIdentityMap.class) {
            return "Weak";
        } else if (identityMapClass == SoftIdentityMap.class) {
            return "Soft";
        }
        return "N/A";
    }

    /**
     * getModuleName(): Answer the name of the context-root of the application that this session is associated with.
     * Answer "unknown" if there is no module name available.
     * Default behavior is to return "unknown"
     */
    public String getModuleName() {
        return ((DatabaseSessionImpl)getSession())
            .getServerPlatform().getModuleName();
    }

    
    /**
     * getApplicationName(): Answer the name of the module (EAR name) that this session is associated with.
     * Answer "unknown" if there is no application name available.
     * Default behavior is to return "unknown"
     */
    public String getApplicationName() {
        return ((WebSphere_7_Platform)((DatabaseSessionImpl)getSession())
                .getServerPlatform()).getApplicationName();
    }
    
    /**
     * PUBLIC: Answer the EclipseLink log level at deployment time. This is read-only.
     */
    public String getDeployedEclipseLinkLogLevel() {
        return getNameForLogLevel(getDeployedSessionLog().getLevel());
    }

    /**
     * PUBLIC: Answer the EclipseLink log level that is changeable.
     * This does not affect the log level in the project (i.e. The next
     * time the application is deployed, changes are forgotten)
     */
    public String getCurrentEclipseLinkLogLevel() {
        return getNameForLogLevel(this.getSession().getSessionLog().getLevel());
    }

    /**
     * PUBLIC: Set the EclipseLink log level to be used at runtime.
     *
     * This does not affect the log level in the project (i.e. The next
     * time the application is deployed, changes are forgotten)
     *
     * @param String newLevel: new log level
     */
    public synchronized void setCurrentEclipseLinkLogLevel(String newLevel) {
        this.getSession().setLogLevel(this.getLogLevelForName(newLevel));
    }

    /**
     * INTERNAL: Answer the name for the log level given.
     *
     * @return String (one of OFF, SEVERE, WARNING, INFO, CONFIG, FINE, FINER, FINEST, ALL)
     */
    private String getNameForLogLevel(int logLevel) {
        switch (logLevel) {
        case SessionLog.ALL:
            return SessionLog.ALL_LABEL;
        case SessionLog.SEVERE:
            return SessionLog.SEVERE_LABEL;
        case SessionLog.WARNING:
            return SessionLog.WARNING_LABEL;
        case SessionLog.INFO:
            return SessionLog.INFO_LABEL;
        case SessionLog.CONFIG:
            return SessionLog.CONFIG_LABEL;
        case SessionLog.FINE:
            return SessionLog.FINE_LABEL;
        case SessionLog.FINER:
            return SessionLog.FINER_LABEL;
        case SessionLog.FINEST:
            return SessionLog.FINEST_LABEL;
        case SessionLog.OFF:
            return SessionLog.OFF_LABEL;
        }
        return "N/A";
    }

    /**
     * INTERNAL: Answer the log level for the given name.
     *
     * @return int for OFF, SEVERE, WARNING, INFO, CONFIG, FINE, FINER, FINEST, ALL
     */
    private int getLogLevelForName(String levelName) {
        if (levelName.equals(SessionLog.ALL_LABEL)) {
            return SessionLog.ALL;
        }
        if (levelName.equals(SessionLog.SEVERE_LABEL)) {
            return SessionLog.SEVERE;
        }
        if (levelName.equals(SessionLog.WARNING_LABEL)) {
            return SessionLog.WARNING;
        }
        if (levelName.equals(SessionLog.INFO_LABEL)) {
            return SessionLog.INFO;
        }
        if (levelName.equals(SessionLog.CONFIG_LABEL)) {
            return SessionLog.CONFIG;
        }
        if (levelName.equals(SessionLog.FINE_LABEL)) {
            return SessionLog.FINE;
        }
        if (levelName.equals(SessionLog.FINER_LABEL)) {
            return SessionLog.FINER;
        }
        if (levelName.equals(SessionLog.FINEST_LABEL)) {
            return SessionLog.FINEST;
        }
        return SessionLog.OFF;
    }

    /**
     *     Method returns if all Parameters should be bound or not
     */
    public Boolean getShouldBindAllParameters() {
        if (!(getSession().getDatasourceLogin() instanceof DatabaseLogin)) {
            return Boolean.FALSE;
        }
        return Boolean.valueOf(((DatabaseLogin)getSession().getDatasourceLogin()).shouldBindAllParameters());
    }

    /**
      *     Return the size of strings after which will be bound into the statement
      *     If we are not using a DatabaseLogin, or we're not using string binding,
      *     answer 0 (zero).
      */
    public Integer getStringBindingSize() {
        if (!(getSession().getDatasourceLogin() instanceof DatabaseLogin)) {
            return Integer.valueOf(0);
        }
        if (!((DatabaseLogin)getSession().getDatasourceLogin()).getPlatform().usesStringBinding()) {
            return Integer.valueOf(0);
        }
        return Integer.valueOf(((DatabaseLogin)getSession().getDatasourceLogin()).getStringBindingSize());
    }

    /**
      *        This method will return if batchWriting is in use or not.
      */
    public Boolean getUsesBatchWriting() {
        return Boolean.valueOf(getSession().getDatasourceLogin().getPlatform().usesBatchWriting());
    }

    /**
      *        This method will return a long indicating the exact time in Milliseconds that the
      *   session connected to the database.
      */
    public Long getTimeConnectionEstablished() {
        return Long.valueOf(((DatabaseSessionImpl)getSession()).getConnectedTime());
    }

    /**
      *        This method will return if batchWriting is in use or not.
      */
    public Boolean getUsesJDBCBatchWriting() {
        return Boolean.valueOf(getSession().getDatasourceLogin().getPlatform().usesJDBCBatchWriting());
    }

    /**
      *     Shows if Byte Array Binding is turned on or not
      */
    public Boolean getUsesByteArrayBinding() {
        return Boolean.valueOf(getSession().getDatasourceLogin().getPlatform().usesByteArrayBinding());
    }

    /**
      *     Shows if native SQL is being used
      */
    public Boolean getUsesNativeSQL() {
        return Boolean.valueOf(getSession().getDatasourceLogin().getPlatform().usesNativeSQL());
    }

    /**
      *     This method indicates if streams are being used for binding
      */
    public Boolean getUsesStreamsForBinding() {
        return Boolean.valueOf(getSession().getDatasourceLogin().getPlatform().usesStreamsForBinding());
    }

    /**
      *     This method indicates if Strings are being bound
      */
    public Boolean getUsesStringBinding() {
        if (!(getSession().getDatasourceLogin() instanceof DatabaseLogin)) {
            return Boolean.FALSE;
        }
        return Boolean.valueOf(((DatabaseLogin)getSession().getDatasourceLogin()).getPlatform().usesStringBinding());
    }

    /**
    *     Returns if statements should be cached or not
    */
    public boolean getShouldCacheAllStatements() {
        if (!(getSession().getDatasourceLogin() instanceof DatabaseLogin)) {
            return Boolean.FALSE;
        }
        return Boolean.valueOf(((DatabaseLogin)getSession().getDatasourceLogin()).shouldCacheAllStatements());
    }

    /**
    *        Returns the statement cache size.  Only valid if statements are being cached
    */
    public int getStatementCacheSize() {
        if (!(getSession().getDatasourceLogin() instanceof DatabaseLogin)) {
            return 0;
        }
        return Integer.valueOf(((DatabaseLogin)getSession().getDatasourceLogin()).getStatementCacheSize());
    }

    /**
    *     Used to clear the statement cache. Only valid if statements are being cached
    */
    public synchronized void clearStatementCache() {
        if (!(getSession().getDatasourceLogin() instanceof DatabaseLogin)) {
            return;
        }
        ((DatabaseAccessor)getSession().getAccessor()).clearStatementCache(getSession());
        ((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_statement_cache_cleared");        
        
    }

    /**
    *        Method returns the value of the Sequence Preallocation size
    */
    public int getSequencePreallocationSize() {
        if (!(getSession().getDatasourceLogin() instanceof DatabaseLogin)) {
            return 0;
        }
        return ((DatasourcePlatform)getSession().getDatasourcePlatform()).getSequencePreallocationSize();        
    }

    /**
    *     This method will print the available Connection pools to the SessionLog.
    * @return void
    */
    public void printAvailableConnectionPools() {
        if (ClassConstants.ServerSession_Class.isAssignableFrom(getSession().getClass())) {
            Map pools = ((ServerSession)getSession()).getConnectionPools();
            Iterator poolNames = pools.keySet().iterator();
            while (poolNames.hasNext()) {
                String poolName = poolNames.next().toString();
                ((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_pool_name", poolName);
            }
        } else {
            ((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_no_connection_pools_available");            
            
        }
    }

    /**
    *     This method will retrieve the max size of a particular connection pool
    * @param poolName the name of the pool to get the max size for
    * @return Integer for the max size of the pool. Return -1 if pool doesn't exist.
    */
    public Integer getMaxSizeForPool(String poolName) {
        if (ClassConstants.ServerSession_Class.isAssignableFrom(getSession().getClass())) {
            ConnectionPool connectionPool = ((ServerSession)getSession()).getConnectionPool(poolName);
            if (connectionPool != null) {
                return Integer.valueOf(connectionPool.getMaxNumberOfConnections());
            }
        }
        return Integer.valueOf(-1);
    }

    /**
    *     This method will retrieve the min size of a particular connection pool
    * @param poolName the name of the pool to get the min size for
    * @return Integer for the min size of the pool. Return -1 if pool doesn't exist.
    */
    public Integer getMinSizeForPool(String poolName) {
        if (ClassConstants.ServerSession_Class.isAssignableFrom(getSession().getClass())) {
            ConnectionPool connectionPool = ((ServerSession)getSession()).getConnectionPool(poolName);
            if (connectionPool != null) {
                return Integer.valueOf(connectionPool.getMinNumberOfConnections());
            }
        }
        return Integer.valueOf(-1);
    }

    /**
    * This method is used to reset connections from the session to the database.  Please
    * Note that this will not work with a SessionBroker at this time
    */
    public synchronized void resetAllConnections() {
        if (ClassConstants.ServerSession_Class.isAssignableFrom(getSession().getClass())) {
            Iterator enumtr = ((ServerSession)getSession()).getConnectionPools().values().iterator();
            while (enumtr.hasNext()) {
                ConnectionPool pool = (ConnectionPool)enumtr.next();
                pool.shutDown();
                pool.startUp();
            }
        } else if (ClassConstants.PublicInterfaceDatabaseSession_Class.isAssignableFrom(getSession().getClass())) {
            getSession().getAccessor().reestablishConnection(getSession());
        }
    }

    /**
    *        This method is used to output those Class Names that have identity Maps in the Session.
    * Please note that SubClasses and aggregates will be missing from this list as they do not have
    * separate identity maps.
    * @return void
    */
    public void printClassesInSession() {
        Vector classes = getSession().getIdentityMapAccessorInstance().getIdentityMapManager().getClassesRegistered();
        int index;
        if (classes.isEmpty()) {
            ((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_no_classes_in_session");            
            return;
        }

        for (index = 0; index < classes.size(); index++) {
            getSession().getSessionLog().log(SessionLog.FINEST, (String)classes.elementAt(index));
        }
    }

    /**
    *        This method will log the objects in the Identity Map.
    * There is no particular order to these objects.
    * @param className the fully qualified classname identifying the identity map
    * @exception  thrown then the IdentityMap for that class name could not be found
    */
    public void printObjectsInIdentityMap(String className) throws ClassNotFoundException {
        Class classWithMap = (Class)getSession().getDatasourcePlatform().getConversionManager().convertObject(className, ClassConstants.CLASS);
        IdentityMap map = getSession().getIdentityMapAccessorInstance().getIdentityMap(classWithMap);

        //check if the identity map exists
        if (null == map) {
            ((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_identity_map_non_existent", className);
            return;
        }

        //check if there are any objects in the identity map. Print if so.
        Enumeration objects = map.keys();
        if (!objects.hasMoreElements()) {
            ((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_identity_map_empty", className);
        }

        CacheKey cacheKey;
        while (objects.hasMoreElements()) {
            cacheKey = (CacheKey)objects.nextElement();
            ((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_print_cache_key_value", 
                    cacheKey.getKey().toString(), cacheKey.getObject().toString());
        }
    }

    /**
    *        This method will log the types of Identity Maps in the session.
    */
    public void printAllIdentityMapTypes() {
        Vector classesRegistered = getSession().getIdentityMapAccessorInstance().getIdentityMapManager().getClassesRegistered();
        String registeredClassName;
        Class registeredClass;

        //Check if there aren't any classes registered
        if (classesRegistered.size() == 0) {
            ((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_no_identity_maps_in_session");
            return;
        }

        //get each identity map, and log the type
        for (int index = 0; index < classesRegistered.size(); index++) {
            registeredClassName = (String)classesRegistered.elementAt(index);
            registeredClass = (Class)getSession().getDatasourcePlatform().getConversionManager().convertObject(registeredClassName, ClassConstants.CLASS);
            IdentityMap map = getSession().getIdentityMapAccessorInstance().getIdentityMap(registeredClass);
            ((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_identity_map_class", 
                    registeredClassName, map.getClass());
        }
    }

    /**
    *        This method will log all objects in all Identity Maps in the session.
    */
    public void printObjectsInIdentityMaps() {
        Vector classesRegistered = getSession().getIdentityMapAccessorInstance().getIdentityMapManager().getClassesRegistered();
        String registeredClassName;

        //Check if there aren't any classes registered
        if (classesRegistered.size() == 0) {
            ((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_no_identity_maps_in_session");
            return;
        }

        //get each identity map, and log the type
        for (int index = 0; index < classesRegistered.size(); index++) {
            registeredClassName = (String)classesRegistered.elementAt(index);
            try {
                this.printObjectsInIdentityMap(registeredClassName);
            } catch (ClassNotFoundException classNotFound) {
                //we are enumerating registered classes, so this shouldn't happen. Print anyway
                classNotFound.printStackTrace();
                AbstractSessionLog.getLog().log(SessionLog.SEVERE, "weblogic_mbean_runtime_exception", classNotFound);
            }
        }
    }

    /**
    *        This method is used to return the number of objects in a particular Identity Map
    * @param className the fully qualified name of the class to get number of instances of.
    * @exception  thrown then the IdentityMap for that class name could not be found
    */
    public Integer getNumberOfObjectsInIdentityMap(String className) throws ClassNotFoundException {
        //BUG 3982060: Always use the root class in combination with the identity map's getSize(class, true) to get an accurate count
        Class classWithIdentityMap = (Class)getSession().getDatasourcePlatform().getConversionManager().convertObject(className, ClassConstants.CLASS);
        Class rootClass = null;

        ClassDescriptor descriptor = getSession().getDescriptor(classWithIdentityMap);
        ClassDescriptor rootDescriptor;

        if (descriptor.hasInheritance()) {
            rootDescriptor = descriptor.getInheritancePolicy().getRootParentDescriptor();
        } else {
            rootDescriptor = descriptor;
        }
        if (rootDescriptor.getCMPPolicy() != null) {
            if (rootDescriptor.getCMPPolicy().getMappedClass() != null) {
                rootClass = rootDescriptor.getCMPPolicy().getMappedClass();
            }
        }

        if (rootClass == null) {
            rootClass = rootDescriptor.getJavaClass();
        }

        return Integer.valueOf(getSession().getIdentityMapAccessorInstance().getIdentityMap(rootClass).getSize(rootClass, true));
    }

    /**
    *        This method will SUM and return the number of objects in all Identity Maps in the session.
    */
    public Integer getNumberOfObjectsInAllIdentityMaps() {
        Vector classesRegistered = getSession().getIdentityMapAccessorInstance().getIdentityMapManager().getClassesRegistered();
        String registeredClassName;
        int sum = 0;

        //Check if there aren't any classes registered
        if (classesRegistered.size() == 0) {
            ((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_no_identity_maps_in_session");
            return Integer.valueOf(0);
        }

        //get each identity map, and log the size
        for (int index = 0; index < classesRegistered.size(); index++) {
            registeredClassName = (String)classesRegistered.elementAt(index);
            try {
                sum += this.getNumberOfObjectsInIdentityMap(registeredClassName).intValue();
            } catch (ClassNotFoundException classNotFound) {
                //we are enumerating registered classes, so this shouldn't happen. Print anyway
                classNotFound.printStackTrace();
                AbstractSessionLog.getLog().log(SessionLog.SEVERE, "weblogic_mbean_runtime_exception", classNotFound);
            }
        }

        return Integer.valueOf(sum);
    }

    /**
     * This method will answer the number of persistent classes contained in the session.
     * This does not include aggregates.
     */
    public Integer getNumberOfPersistentClasses() {
        Hashtable classesTable = new Hashtable();
        ClassDescriptor currentDescriptor;

        //use a table to eliminate duplicate classes. Ignore Aggregates
        Iterator descriptors = getSession().getProject().getDescriptors().values().iterator();
        while (descriptors.hasNext()) {
            currentDescriptor = (ClassDescriptor)descriptors.next();
            if (!currentDescriptor.isAggregateDescriptor()) {
                classesTable.put(currentDescriptor.getJavaClassName(), Boolean.TRUE);
            }
        }

        return Integer.valueOf(classesTable.size());
    }

    /**
    * Return the log type, either "EclipseLink",  "Java" or the simple name of the logging class used.  
    *
    * @return the log type
    */
    public String getLogType() {
        if (this.getSession().getSessionLog().getClass() == JavaLog.class) {
            return "Java";
        } else if (this.getSession().getSessionLog().getClass() == DefaultSessionLog.class) {
            return EclipseLink_Product_Name;
        } else {
            return this.getSession().getSessionLog().getClass().getSimpleName();
        }
    }

    /**
    * Return the database platform used by the DatabaseSession.
    *
    * @return String databasePlatform
    */
    public String getDatabasePlatform() {
        return getSession().getDatasourcePlatform().getClass().getName();
    }

    /**
    *        Return JDBCConnection detail information. This includes URL and datasource information.
    */
    public synchronized String getJdbcConnectionDetails() {
        return getSession().getLogin().getConnector().getConnectionDetails();
    }

    /**
    *        Return connection pool type. Values include: "Internal", "External" and "N/A".
    */
    public synchronized String getConnectionPoolType() {
        if (getSession().getLogin().shouldUseExternalConnectionPooling()) {
            return "External";
        } else {
            return "N/A";
        }
    }

    /**
    *        Return db driver class name. This only applies to DefaultConnector. Return "N/A" otherwise.
    */
    public synchronized String getDriver() {
        if (getSession().getLogin().getConnector() instanceof DefaultConnector) {
            return getSession().getLogin().getDriverClassName();
        }
        return "N/A";
    }

    /**
    * Return the log filename. This returns the fully qualified path of the log file when
    * EclipseLink DefaultSessionLog instance is used. Null is returned otherwise.
    *
    * @return String logFilename
    */
    public String getLogFilename() {
        // returns String or null.
        if ( session.getSessionLog() instanceof DefaultSessionLog) {
                return ((DefaultSessionLog)session.getSessionLog()).getWriterFilename();
        } else {
            return null;
        }
    }

    /**
    *    This method is used to initialize the identity maps in the session.
    */
    public synchronized void initializeAllIdentityMaps() {
        getSession().getIdentityMapAccessor().initializeAllIdentityMaps();
    }

    /**
    *    This method is used to initialize the identity maps specified by the Vector of classNames.
    *
    * @param classNames String[] of fully qualified classnames identifying the identity maps to initialize
    */
    public synchronized void initializeIdentityMaps(String[] classNames) throws ClassNotFoundException {
        for (int index = 0; index < classNames.length; index++) {
            initializeIdentityMap(classNames[index]);
        }
    }

    /**
    *    This method is used to invalidate the identity maps in the session.
    */
    public synchronized void invalidateAllIdentityMaps() {
        Vector classesRegistered = getSession().getIdentityMapAccessorInstance().getIdentityMapManager().getClassesRegistered();
        String registeredClassName;
        Class registeredClass;

        if (classesRegistered.isEmpty()) {
            getSession().getSessionLog().info("There are no Identity Maps in this session");
            ((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_no_identity_maps_in_session");            
        }

        //get each identity map, and invalidate
        for (int index = 0; index < classesRegistered.size(); index++) {
            registeredClassName = (String)classesRegistered.elementAt(index);
            registeredClass = (Class)getSession().getDatasourcePlatform().getConversionManager()
                .convertObject(registeredClassName, ClassConstants.CLASS);
            getSession().getIdentityMapAccessor().invalidateClass(registeredClass);
            ((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_identity_map_invalidated", registeredClassName);
        }
    }

    /**
    *    This method is used to invalidate the identity maps specified by the String[] of classNames.
    *
    * @param classNames String[] of fully qualified classnames identifying the identity maps to invalidate
    * @param recurse    Boolean indicating if we want to invalidate the children identity maps too
    */
    public synchronized void invalidateIdentityMaps(String[] classNamesParam, Boolean recurse) throws ClassNotFoundException {
        String[] classNames = classNamesParam;
        for (int index = 0; index < classNames.length; index++) {
            invalidateIdentityMap(classNames[index], recurse);
        }
    }

    /**
    *    This method is used to invalidate the identity maps specified by className. This does not
    * invalidate the children identity maps
    *
    * @param className the fully qualified classname identifying the identity map to invalidate
    */
    public synchronized void invalidateIdentityMap(String className) throws ClassNotFoundException {
        this.invalidateIdentityMap(className, Boolean.FALSE);
    }

    /**
    *    This method is used to invalidate the identity maps specified by className.
    *
    * @param className the fully qualified classname identifying the identity map to invalidate
    * @param recurse    Boolean indicating if we want to invalidate the children identity maps too
    */
    public synchronized void invalidateIdentityMap(String className, Boolean recurse) throws ClassNotFoundException {
        Class registeredClass;

        //get identity map, and invalidate
        registeredClass = (Class)getSession().getDatasourcePlatform().getConversionManager()
            .convertObject(className, ClassConstants.CLASS);
        getSession().getIdentityMapAccessor().invalidateClass(registeredClass);
        ((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_identity_map_invalidated", className);
    }

    /**
     * 
    * INTERNAL:
     * Convert the TabularData to a two-dimensional array
     * @param tdata the TabularData to be converted
     * @param names the order of the columns
     * @return a two-dimensional array
     * @throws Exception
     */
    private Object[][] tabularDataTo2DArray(TabularData tdata, String[] names) throws Exception {
        if(tdata==null){
            return null;
        }
        Object[] rows = tdata.values().toArray();
        Object[][] data = new Object[rows.length][];

        for (int i=0; i<rows.length; i++) {
            data[i] = ((CompositeData) rows[i]).getAll(names);
        }
        return data;
    }
    
    
    /**
     * Return whether this session is an EclipseLink JPA session.
     * The absence of this function or a value of false will signify that the session
     * belongs to a provider other than EclipseLink.  
     * @return
     */
    public boolean isJPASession() {
        return true;
    }
}

Return to bug 316513

Line 0 Link Here

(-)foundation/org.eclipse.persistence.core/src/org/eclipse/persistence/platform/server/JMXServerPlatformBase.java (+265 lines)
		1	package org.eclipse.persistence.platform.server;
		2
		3	import javax.management.InstanceAlreadyExistsException;
		4	import javax.management.InstanceNotFoundException;
		5	import javax.management.MBeanRegistrationException;
		6	import javax.management.MBeanServer;
		7	import javax.management.MBeanServerFactory;
		8	import javax.management.MalformedObjectNameException;
		9	import javax.management.ObjectInstance;
		10	import javax.management.ObjectName;
		11
		12	import org.eclipse.persistence.logging.AbstractSessionLog;
		13	import org.eclipse.persistence.logging.SessionLog;
		14	import org.eclipse.persistence.services.mbean.MBeanDevelopmentServices;
		15	import org.eclipse.persistence.services.mbean.MBeanRuntimeServicesMBean;
		16	import org.eclipse.persistence.sessions.DatabaseSession;
		17
		18	public abstract class JMXServerPlatformBase extends ServerPlatformBase {// implements JMXEnabledPlatform {
		19
		20	/** Cache the JBoss MBeanServer for performance */
		21	private MBeanServer mBeanServer = null;
		22
		23	/** cache the RuntimeServices MBean */
		24	private MBeanRuntimeServicesMBean runtimeServicesMBean = null;
		25
		26	/** moduleName determination is available during MBean registration only */
		27	private String moduleName = null;
		28
		29	/** applicationName determination is available during MBean registration only */
		30	private String applicationName = null;
		31
		32	/**
		33	* INTERNAL:
		34	* Default Constructor: Initialize so that runtime services and JTA are enabled. Set the DatabaseSession that I
		35	* will be helping.
		36	*/
		37	public JMXServerPlatformBase(DatabaseSession newDatabaseSession) {
		38	super(newDatabaseSession);
		39	/**
		40	* INTERNAL:
		41	* Answer "unknown" as a default for platforms that do not implement getModuleName()
		42	*/
		43	applicationName = DEFAULT_SERVER_NAME_AND_VERSION;
		44	moduleName = DEFAULT_SERVER_NAME_AND_VERSION;
		45	}
		46
		47	public MBeanServer getMBeanServer() {
		48	// lazy initialize the MBeanServer reference
		49	if(null == mBeanServer) {
		50	try {
		51	mBeanServer = (MBeanServer) MBeanServerFactory.findMBeanServer(null).get(0);
		52	} catch (Exception e) {
		53	e.printStackTrace();
		54	}
		55	}
		56	return mBeanServer;
		57	}
		58
		59	/**
		60	* INTERNAL:
		61	* serverSpecificRegisterMBean(): Server specific implementation of the
		62	* creation and deployment of the JMX MBean to provide runtime services for my
		63	* databaseSession.
		64	*
65	* @return void
66	* @see #isRuntimeServicesEnabled()
67	* @see #disableRuntimeServices()
68	* @see #registerMBean()
69	*/
70	public void genericRegisterMBean(MBeanRuntimeServicesMBean servicesMBean) {
71	// get and cache module and application name during registration
72	//initializeApplicationNameAndModuleName();
73	MBeanServer mBeanServerRuntime = getMBeanServer();
74	ObjectName name = null;
75	String sessionName = getMBeanSessionName();
76	if (null != sessionName && (shouldRegisterDevelopmentBean \|\| shouldRegisterRuntimeBean)) {
77	try {
78	// Attempt to register new mBean with the server
79	if (null != mBeanServerRuntime && shouldRegisterDevelopmentBean) {
80	try {
81	name = new ObjectName(JMX_REGISTRATION_PREFIX + "Development-" + sessionName + ",Type=Configuration");
82	} catch (MalformedObjectNameException mne) {
83	AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", mne);
84	} catch (Exception exception) {
85	AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", exception);
86	}
87
88	MBeanDevelopmentServices developmentMBean = new MBeanDevelopmentServices(getDatabaseSession());
89	ObjectInstance info = null;
90	try {
91	info = mBeanServerRuntime.registerMBean(developmentMBean, name);
92	} catch(InstanceAlreadyExistsException iaee) {
93	AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", iaee);
94	} catch (MBeanRegistrationException registrationProblem) {
95	AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", registrationProblem);
96	} catch (Exception e) {
97	AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", e);
98	}
99	AbstractSessionLog.getLog().log(SessionLog.FINEST, "registered_mbean", info);
100	}
101
102	if (null != mBeanServerRuntime && shouldRegisterRuntimeBean) {
103	try {
104	name = new ObjectName(JMX_REGISTRATION_PREFIX + "Session(" + sessionName + ")");
105	} catch (MalformedObjectNameException mne) {
106	AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", mne);
107	} catch (Exception exception) {
108	AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", exception);
109	}
110
111	ObjectInstance runtimeInstance = null;
112	try {
113	runtimeInstance = mBeanServerRuntime.registerMBean(servicesMBean, name);
114	setRuntimeServicesMBean(servicesMBean);
115	} catch(InstanceAlreadyExistsException iaee) {
116	AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", iaee);
117	} catch (MBeanRegistrationException registrationProblem) {
118	AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", registrationProblem);
119	} catch (Exception e) {
120	AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", e);
121	}
122	AbstractSessionLog.getLog().log(SessionLog.FINEST, "registered_mbean", runtimeInstance);
123	}
124	} catch (Exception exception) {
125	AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_registering_mbean", exception);
126	}
127	}
128	}
129
130	/**
131	* INTERNAL:
132	* serverSpecificUnregisterMBean(): Server specific implementation of the
133	* de-registration of the JMX MBean from its server during session logout.
134	*
135	* @return void
136	* @see #isRuntimeServicesEnabled()
137	* @see #disableRuntimeServices()
138	*/
139	public void serverSpecificUnregisterMBean() {
140	MBeanServer mBeanServerRuntime = getMBeanServer();
141	ObjectName name = null;
142	String sessionName = getMBeanSessionName();
143	if (null != sessionName && (shouldRegisterDevelopmentBean \|\| shouldRegisterRuntimeBean)) {
144	try {
145
146	// Attempt to register new mBean with the server
147	if (shouldRegisterDevelopmentBean) {
148	try {
149	name = new ObjectName(JMX_REGISTRATION_PREFIX + "Development_" + sessionName + ",Type=Configuration");
150	} catch (MalformedObjectNameException mne) {
151	AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_unregistering_mbean", mne);
152	} catch (Exception exception) {
153	AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_unregistering_mbean", exception);
154	}
155
156	AbstractSessionLog.getLog().log(SessionLog.FINEST, "unregistering_mbean", name);
157	try {
158	mBeanServerRuntime.unregisterMBean(name);
159	} catch(InstanceNotFoundException inf) {
160	AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_unregistering_mbean", inf);
161	} catch (MBeanRegistrationException mbre) {
162	AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_unregistering_mbean", mbre);
163	}
164	}
165
166	if (shouldRegisterRuntimeBean) {
167	try {
168	name = new ObjectName(JMX_REGISTRATION_PREFIX + "Session(" + sessionName + ")");
169	} catch (MalformedObjectNameException mne) {
170	AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_unregistering_mbean", mne);
171	} catch (Exception exception) {
172	AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_unregistering_mbean", exception);
173	}
174
175	AbstractSessionLog.getLog().log(SessionLog.FINEST, "unregistering_mbean", name);
176	try {
177	mBeanServerRuntime.unregisterMBean(name);
178	} catch(InstanceNotFoundException inf) {
179	AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_unregistering_mbean", inf);
180	} catch (MBeanRegistrationException registrationProblem) {
181	AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_unregistering_mbean", registrationProblem);
182	}
183	}
184	} catch (Exception exception) {
185	AbstractSessionLog.getLog().log(SessionLog.WARNING, "problem_unregistering_mbean", exception);
186	} finally {
187	// de reference the mbean
188	this.setRuntimeServicesMBean(null);
189	}
190	}
191	}
192
193	/**
194	* Remove JMX reserved characters from the session name
195	* @param aSession
196	* @return
197	*/
198	protected String getMBeanSessionName() {
199	// Check for a valid session - should never occur though
200	if(null != getDatabaseSession() && null != getDatabaseSession().getName()) {
201	// remove any JMX reserved characters when the session name is file:/drive:/directory
202	return getDatabaseSession().getName().replaceAll("[=,:]", "_");
203	} else {
204	AbstractSessionLog.getLog().log(SessionLog.WARNING, "session_key_for_mbean_name_is_null");
205	return null;
206	}
207	}
208
209
210	protected MBeanRuntimeServicesMBean getRuntimeServicesMBean() {
211	return runtimeServicesMBean;
212	}
213
214	protected void setRuntimeServicesMBean(
215	MBeanRuntimeServicesMBean runtimeServicesMBean) {
216	this.runtimeServicesMBean = runtimeServicesMBean;
217	}
218
219	/**
220	* INTERNAL:
221	* getModuleName(): Answer the name of the context-root of the application that this session is associated with.
222	* Answer "unknown" if there is no module name available.
223	* Default behavior is to return "unknown" - we override this behavior here for JBoss.
224	*
225	* There are 4 levels of implementation.
226	* 1) use the property override jboss.moduleName, or
227	* 2) perform a reflective jboss.work.executeThreadRuntime.getModuleName() call, or
228	* 3) extract the moduleName:persistence_unit from the jboss classloader string representation, or
229	* 3) defer to superclass - usually return "unknown"
230	*
231	* @return String moduleName
232	*/
233	@Override
234	public String getModuleName() {
235	return this.moduleName;
236	}
237
238	protected void setModuleName(String aName) {
239	moduleName = aName;
240	}
241
242	/**
243	* INTERNAL:
244	* getApplicationName(): Answer the name of the module (EAR name) that this session is associated with.
245	* Answer "unknown" if there is no application name available.
246	* Default behavior is to return "unknown" - we override this behavior here for JBoss.
247	*
248	* There are 4 levels of implementation.
249	* 1) use the property override weblogic.applicationName, or
250	* 2) perform a reflective weblogic.work.executeThreadRuntime.getApplicationName() call, or
251	* 3) extract the moduleName:persistence_unit from the weblogic classloader string representation, or
252	* 3) defer to superclass - usually return "unknown"
253	*
254	* @return String applicationName
255	*/
256	public String getApplicationName() {
257	return this.applicationName;
258	}
259
260
261	public void setApplicationName(String aName) {
262	applicationName = aName;
263	}
264
265	}

Line 0 Link Here

(-)foundation/org.eclipse.persistence.core/src/org/eclipse/persistence/services/jboss/ClassSummaryDetail.java (+39 lines)
	1	/*******************************************************************************
	2	* Copyright (c) 1998, 2010 Oracle. All rights reserved.
	3	* This program and the accompanying materials are made available under the
	4	* terms of the Eclipse Public License v1.0 and Eclipse Distribution License v. 1.0
	5	* which accompanies this distribution.
	6	* The Eclipse Public License is available at http://www.eclipse.org/legal/epl-v10.html
	7	* and the Eclipse Distribution License is available at
	8	* http://www.eclipse.org/org/documents/edl-v10.php.
	9	*
	10	* Contributors:
	11	* @author mobrien
	12	* @since EclipseLink 2.2 enh# 316511
	13	* 06/22/2010-2.2 Michael O'Brien
	14	* - 316511: Add JBoss specific JMX MBean attributes and functions
	15	* see <link>http://wiki.eclipse.org/EclipseLink/DesignDocs/316513</link>
	16	******************************************************************************/
	17	package org.eclipse.persistence.services.jboss;
	18
	19	import org.eclipse.persistence.services.ClassSummaryDetailBase;
	20
	21	/**
	22	* The class is used internally by the Portable JMX Framework to convert
	23	* model specific classes into Open Types so that the attributes of model class can
	24	* be exposed by MBeans.
	25	*/
	26	public class ClassSummaryDetail extends ClassSummaryDetailBase {
	27
	28	public static final String COMPOSITE_TYPE_TYPENAME = "org.eclipse.persistence.services.jboss";
	29	public static final String COMPOSITE_TYPE_DESCRIPTION = "org.eclipse.persistence.services.jboss.ClassSummaryDetail";
	30
	31	/**
	32	* Construct a ClassSummaryDetail instance. The PropertyNames annotation is used
	33	* to be able to construct a ClassSummaryDetail instance out of a CompositeData
	34	* instance. See MXBeans documentation for more details.
	35	*/
	36	public ClassSummaryDetail(String className, String cacheType, String configuredSize,String currentSize , String parentClassName) {
	37	super(className, cacheType, configuredSize, currentSize , parentClassName);
	38	}
	39	}

Lines 83-98 Link Here

(-)foundation/org.eclipse.persistence.core/src/org/eclipse/persistence/services/weblogic/WebLogicRuntimeServices.java (-161 / +1 lines)
83	*/	83	*/
84	public class WebLogicRuntimeServices extends RuntimeServices {	84	public class WebLogicRuntimeServices extends RuntimeServices {
85		85
86	/** This is the profile weight at server startup time. This is read-only */
87	private int deployedSessionProfileWeight;
88
89	/** This contains the session log from server startup time. This is read-only. */
90	private SessionLog deployedSessionLog;
91
92	public String objectName;
93
94	private static final String EclipseLink_Product_Name = "EclipseLink";
95
96	/**	86	/**
97	* PUBLIC:	87	* PUBLIC:
98	* Default Constructor	88	* Default Constructor
Lines 106-112 Link Here
106	* Create an instance of WebLogicRuntimeServices to be associated with the provided session	96	* Create an instance of WebLogicRuntimeServices to be associated with the provided session
107	*	97	*
108	* @param session The session to be used with these RuntimeServices	98	* @param session The session to be used with these RuntimeServices
109	* @param String myBaseObjectName: "weblogic:....." (The JMX object name before it's wrapped in a ObjectName)
110	*/	99	*/
111	public WebLogicRuntimeServices(AbstractSession session) {	100	public WebLogicRuntimeServices(AbstractSession session) {
112	super();	101	super();
Lines 133-151 Link Here
133	this.updateDeploymentTimeData();	122	this.updateDeploymentTimeData();
134	}	123	}
135		124
136	/**
137	* INTERNAL:
138	* Define the deployment time data associated with logging and profiling
139	*
140	*/
141	protected void updateDeploymentTimeData() {
142	this.deployedSessionLog = (SessionLog)((AbstractSessionLog)session.getSessionLog()).clone();
143	if (session.getProfiler() == null) {
144	this.deployedSessionProfileWeight = -1;//there is no profiler
145	} else {
146	this.deployedSessionProfileWeight = session.getProfiler().getProfileWeight();
147	}
148	}
149		125
150	/**	126	/**
151	* Answer the name of the EclipseLink session this MBean represents.	127	* Answer the name of the EclipseLink session this MBean represents.
Lines 613-619 Link Here
613	* PUBLIC: Answer the EclipseLink log level at deployment time. This is read-only.	589	* PUBLIC: Answer the EclipseLink log level at deployment time. This is read-only.
614	*/	590	*/
615	public String getDeployedEclipseLinkLogLevel() {	591	public String getDeployedEclipseLinkLogLevel() {
616	return getNameForLogLevel(this.deployedSessionLog.getLevel());	592	return getNameForLogLevel(getDeployedSessionLog().getLevel());
617	}	593	}
618		594
619	/**	595	/**
Lines 700-754 Link Here
700	}	676	}
701		677
702	/**	678	/**
703	* This method is used to get the type of profiling.
704	* Possible values are: "EclipseLink" or "None".
705	*/
706	public synchronized String getProfilingType() {
707	if (getUsesEclipseLinkProfiling().booleanValue()) {
708	return EclipseLink_Product_Name;
709	} else {
710	return "None";
711	}
712	}
713
714	/**
715	* This method is used to select the type of profiling.
716	* Valid values are: "EclipseLink" or "None". These values are not case sensitive.
717	* null is considered to be "None".
718	*/
719	public synchronized void setProfilingType(String profileType) {
720	if ((profileType == null) \|\| (profileType.compareToIgnoreCase("None") == 0)) {
721	this.setUseNoProfiling();
722	} else if (profileType.compareToIgnoreCase(EclipseLink_Product_Name) == 0) {
723	this.setUseEclipseLinkProfiling();
724	}
725	}
726
727	/**
728	* This method is used to turn on EclipseLink Performance Profiling
729	*/
730	public void setUseEclipseLinkProfiling() {
731	if (getUsesEclipseLinkProfiling().booleanValue()) {
732	return;
733	}
734	getSession().setProfiler(new PerformanceProfiler());
735	}
736
737	/**
738	* This method answers true if EclipseLink Performance Profiling is on.
739	*/
740	public Boolean getUsesEclipseLinkProfiling() {
741	return Boolean.valueOf(getSession().getProfiler() instanceof PerformanceProfiler);
742	}
743
744	/**
745	* This method is used to turn off all Performance Profiling, DMS or EclipseLink.
746	*/
747	public void setUseNoProfiling() {
748	getSession().setProfiler(null);
749	}
750
751	/**
752	* Method returns if all Parameters should be bound or not	679	* Method returns if all Parameters should be bound or not
753	*/	680	*/
754	public Boolean getShouldBindAllParameters() {	681	public Boolean getShouldBindAllParameters() {
Lines 1113-1191 Link Here
1113	}	1040	}
1114		1041
1115	/**	1042	/**
1116	* This method will log the instance level locks in all Identity Maps in the session.
1117	*/
1118	public void printIdentityMapLocks() {
1119	getSession().getIdentityMapAccessorInstance().getIdentityMapManager().printLocks();
1120	}
1121
1122	/**
1123	* This method will log the instance level locks in the Identity Map for the given class in the session.
1124	*/
1125	public void printIdentityMapLocks(String registeredClassName) {
1126	Class registeredClass = (Class)getSession().getDatasourcePlatform().getConversionManager()
1127	.convertObject(registeredClassName, ClassConstants.CLASS);
1128	getSession().getIdentityMapAccessorInstance().getIdentityMapManager().printLocks(registeredClass);
1129	}
1130
1131	/**
1132	* This method assumes EclipseLink Profiling (as opposed to Java profiling).
1133	* This will log at the INFO level a summary of all elements in the profile.
1134	*/
1135	public void printProfileSummary() {
1136	if (!this.getUsesEclipseLinkProfiling().booleanValue()) {
1137	return;
1138	}
1139	PerformanceProfiler performanceProfiler = (PerformanceProfiler)getSession().getProfiler();
1140	getSession().getSessionLog().info(performanceProfiler.buildProfileSummary().toString());
1141	}
1142
1143	/**
1144	* INTERNAL:
1145	* utility method to get rid of leading and trailing {}'s
1146	*/
1147	private String trimProfileString(String originalProfileString) {
1148	String trimmedString;
1149
1150	if (originalProfileString.length() > 1) {
1151	trimmedString = originalProfileString.substring(0, originalProfileString.length());
1152	if ((trimmedString.charAt(0) == '{') && (trimmedString.charAt(trimmedString.length() - 1) == '}')) {
1153	trimmedString = trimmedString.substring(1, trimmedString.length() - 1);
1154	}
1155	return trimmedString;
1156	} else {
1157	return originalProfileString;
1158	}
1159	}
1160
1161	/**
1162	* This method assumes EclipseLink Profiling (as opposed to Java profiling).
1163	* This will log at the INFO level a summary of all elements in the profile, categorized
1164	* by Class.
1165	*/
1166	public void printProfileSummaryByClass() {
1167	if (!this.getUsesEclipseLinkProfiling().booleanValue()) {
1168	return;
1169	}
1170	PerformanceProfiler performanceProfiler = (PerformanceProfiler)getSession().getProfiler();
1171	//trim the { and } from the beginning at end, because they cause problems for the logger
1172	getSession().getSessionLog().info(trimProfileString(performanceProfiler.buildProfileSummaryByClass().toString()));
1173	}
1174
1175	/**
1176	* This method assumes EclipseLink Profiling (as opposed to Java profiling).
1177	* This will log at the INFO level a summary of all elements in the profile, categorized
1178	* by Query.
1179	*/
1180	public void printProfileSummaryByQuery() {
1181	if (!this.getUsesEclipseLinkProfiling().booleanValue()) {
1182	return;
1183	}
1184	PerformanceProfiler performanceProfiler = (PerformanceProfiler)getSession().getProfiler();
1185	getSession().getSessionLog().info(trimProfileString(performanceProfiler.buildProfileSummaryByQuery().toString()));
1186	}
1187
1188	/**
1189	* Return the log type, either "EclipseLink", "Java" or the simple name of the logging class used.	1043	* Return the log type, either "EclipseLink", "Java" or the simple name of the logging class used.
1190	*	1044	*
1191	* @return the log type	1045	* @return the log type
Lines 1271-1290 Link Here
1271	}	1125	}
1272		1126
1273	/**	1127	/**
1274	* This method is used to initialize the identity maps specified by className.
1275	* @param className the fully qualified classnames identifying the identity map to initialize
1276	*/
1277	public synchronized void initializeIdentityMap(String className) throws ClassNotFoundException {
1278	Class registeredClass;
1279
1280	//get identity map, and initialize
1281	registeredClass = (Class)getSession().getDatasourcePlatform().getConversionManager()
1282	.convertObject(className, ClassConstants.CLASS);
1283	getSession().getIdentityMapAccessor().initializeIdentityMap(registeredClass);
1284	((AbstractSession)session).log(SessionLog.INFO, SessionLog.SERVER, "jmx_mbean_runtime_services_identity_map_initialized", className);
1285	}
1286
1287	/**
1288	* This method is used to invalidate the identity maps in the session.	1128	* This method is used to invalidate the identity maps in the session.
1289	*/	1129	*/
1290	public synchronized void invalidateAllIdentityMaps() {	1130	public synchronized void invalidateAllIdentityMaps() {