Skip navigation links

com.tangosol.net.management
Class MBeanHelper

java.lang.Object
com.tangosol.util.Base
com.tangosol.net.management.MBeanHelper

Direct Known Subclasses:

MBeanConnector

public abstract class MBeanHelper

extends Base

Helper class providing various functionality related to aggregation of attributes and methods exposed by Coherence JMX framework MBeans.

Since:

Coherence 3.3

Author:

gg 2007/01/02

Field Summary

static java.util.Map	SCALAR_SIMPLETYPES A map of scalar SimpleTypes (classes) keyed by the corresponding JMX signatures.
static java.util.Map	SCALAR_TYPES A map of scalar types (classes) keyed by the corresponding JMX signatures.

Constructor Summary

MBeanHelper()

Method Summary

static int	compareKeyList(javax.management.ObjectName oname1, javax.management.ObjectName oname2) Compare two global MBean names forcing numeric comparison of the node ID while using string comparison on all other key properties.
static javax.management.DynamicMBean	createMapAdapterMbean(java.util.Map mapDescr, java.util.Map mapValue) Create a DynamicMBean driven by maps containing attribute descriptions and values.
static MBeanReference	ensureSingletonMBean(java.lang.String sName) Ensure that there is an instance of a local MBean of the specified type registered with the default MBeansServer.
static javax.management.MBeanServer	findMBeanServer() Find an MBeanServer that Coherence MBeans are registered with.
static javax.management.MBeanServer	findMBeanServer(java.lang.String sDefaultDomain) Find an MBeanServer that has the specified default domain name.
protected static java.lang.reflect.Method	findMethod(java.lang.Class clzMBean, javax.management.MBeanOperationInfo op) Find a Method for the specified MBeanOperationInfo in the specified MBean class or interface.
protected static java.lang.reflect.Method	findMethod(java.lang.Class clz, java.lang.String sName, java.lang.String[] asParamTypes) Find a Method with the specified name and parameter types in the specified class.
static java.lang.String	getDefaultDomain() Return the the default domain name as configured in the Coherence operational configuration descriptor ("default-domain-name" element).
static java.lang.String	getDescription(java.lang.Class clzMBeanIface, javax.management.MBeanAttributeInfo info) Retrieve a description for a particular attribute by finding a Description annotation on the getter method for the attribute.
static java.lang.String	getDescription(java.lang.Class clzMBeanIface, javax.management.MBeanInfo info) Retrieve the description for the MBean from the MBean interface annotation.
static java.lang.String	getDescription(java.lang.Class clzMBeanIface, javax.management.MBeanOperationInfo info) Retrieve a description for the particular MBeanOperationInfo by finding a Description annotation on the corresponding method.
static javax.management.MBeanNotificationInfo[]	getNotificationInfo(java.lang.Class clzMBeanIface) Return an MBeanNotificationInfo if a Notification annotation is present on the provided MBean interface.
protected static java.lang.annotation.Annotation	getParameterAnnotation(java.lang.reflect.Method meth, int iParam, java.lang.Class clzAnno) Retrieve an Annotation for a parameter to a method.
static java.lang.String	getParameterName(java.lang.Class clzMBeanIface, javax.management.MBeanOperationInfo infoOp, javax.management.MBeanParameterInfo infoParam, int iParam) Retrieve the parameter name for the specified parameter by finding a Description annotation on the corresponding method.
static boolean	hasDomain(java.lang.String sCanonical) Return true if the Canonical name is prefixed with the domain name.
static boolean	isQuoteRequired(java.lang.String s) Determine if the string requires quotes.
static java.lang.String	quote(java.lang.String s) Create an escape-sequence string that allows for special characters to be included in a JMX ObjectName.
static java.lang.String	quoteCanonical(java.lang.String sCanonical) Return a quoted KeyPropertyString or a quoted canonical name.
static void	registerCacheMBean(CacheService service, java.lang.String sCacheName, java.lang.String sContext, java.util.Map map) Register the specified map with the cluster registry.
static void	registerCacheMBean(NamedCache cache, java.lang.String sContext) Register the specified NamedCache with the cluster registry.
static void	registerQueryMBeans(java.lang.String sMBeanServerDomain, java.lang.String sQuery, java.lang.String sPrefix, Registry registry) Find all MBeans matching to the specified query at a local MBeanServer and register them with the specified Registry.
static java.lang.Object	startHttpConnector(int nPort, javax.management.MBeanServer mbs) Start a com.sun.jdmk.comm.HtmlAdaptorServer, which is a part of the Sun JMX reference implementation.
static javax.management.remote.JMXConnectorServer	startRmiConnector(java.lang.String sHost, int nRegPort, int nConPort, javax.management.MBeanServer mbs, java.util.Map mapEnv) Start a JMXConnectorServer.
static java.lang.String	stripDomain(java.lang.String sCanonical) Remove the domain prefix from the canonical name if one exists.
static java.lang.String	unquote(java.lang.String s) Convert a string returned from the quote(java.lang.String) method to the original string.
static void	unregisterCacheMBean(CacheService service, java.lang.String sCacheName) Unregister all managed objects that are related to the specified cache from the registry.
static void	unregisterCacheMBean(java.lang.String sCacheName, java.lang.String sContext) Unregister all managed objects related to the given cache name and context from the cluster registry.

Field Detail

SCALAR_TYPES

public static final java.util.Map SCALAR_TYPES

A map of scalar types (classes) keyed by the corresponding JMX signatures.

See Also:

JMX 1.2 specification; Chapter 3, Basic Data Types

SCALAR_SIMPLETYPES

public static final java.util.Map SCALAR_SIMPLETYPES

A map of scalar SimpleTypes (classes) keyed by the corresponding JMX signatures.

Constructor Detail

MBeanHelper

public MBeanHelper()

Method Detail

getDefaultDomain

public static java.lang.String getDefaultDomain()

Return the the default domain name as configured in the Coherence operational configuration descriptor ("default-domain-name" element).

Returns:

the default domain name

findMBeanServer

public static javax.management.MBeanServer findMBeanServer()

Find an MBeanServer that Coherence MBeans are registered with.

Returns:

an existing or a new MBeanServer with the default domain name as configured in the Coherence operational configuration descriptor

findMBeanServer

public static javax.management.MBeanServer findMBeanServer(java.lang.String sDefaultDomain)

Find an MBeanServer that has the specified default domain name. If the domain name is not specified, any existing MBeanServer is chosen.

Parameters:

sDefaultDomain - the default domain name

Returns:

an existing or a new MBeanServer with the specified default domain name

registerQueryMBeans

public static void registerQueryMBeans(java.lang.String sMBeanServerDomain,
                                       java.lang.String sQuery,
                                       java.lang.String sPrefix,
                                       Registry registry)

Find all MBeans matching to the specified query at a local MBeanServer and register them with the specified Registry.

Note: the MBeanServer that the query runs against is not necessarily the one used by the Registry.

Parameters:

sMBeanServerDomain - the default domain of the MBeanServer where the query should be executed. If this value is empty or null the Coherence default domain is used

sQuery - a JMX query string that will be used to find the MBeans

sPrefix - a target location to prepend to converted MBean names

registry - a Registry to register the JMX query results with

registerCacheMBean

public static void registerCacheMBean(NamedCache cache,
                                      java.lang.String sContext)

Register the specified NamedCache with the cluster registry.

Parameters:

cache - the NamedCache object to register

sContext - the cache context (tier)

registerCacheMBean

public static void registerCacheMBean(CacheService service,
                                      java.lang.String sCacheName,
                                      java.lang.String sContext,
                                      java.util.Map map)

Register the specified map with the cluster registry.

Parameters:

service - the CacheService that the cache belongs to

sCacheName - the cache name

sContext - the cache context (tier)

map - the map object to register

unregisterCacheMBean

public static void unregisterCacheMBean(CacheService service,
                                        java.lang.String sCacheName)

Unregister all managed objects that are related to the specified cache from the registry.

Parameters:

service - the CacheService that the cache belongs to

sCacheName - the cache name

unregisterCacheMBean

public static void unregisterCacheMBean(java.lang.String sCacheName,
                                        java.lang.String sContext)

Unregister all managed objects related to the given cache name and context from the cluster registry.

Parameters:

sCacheName - the cache name

sContext - the cache context (tier)

ensureSingletonMBean

public static MBeanReference ensureSingletonMBean(java.lang.String sName)

Ensure that there is an instance of a local MBean of the specified type registered with the default MBeansServer.

Parameters:

sName - an MBean name

Returns:

the MBeanReference for the registered MBean

createMapAdapterMbean

public static javax.management.DynamicMBean createMapAdapterMbean(java.util.Map mapDescr,
                                                                  java.util.Map mapValue)

Create a DynamicMBean driven by maps containing attribute descriptions and values.

Parameters:

mapDescr - Map<String, String> keyed by the attribute names with values being attribute descriptions

mapValue - Map<String, Object> keyed by the attribute names with values being attribute values

startRmiConnector

public static javax.management.remote.JMXConnectorServer startRmiConnector(java.lang.String sHost,
                                                                           int nRegPort,
                                                                           int nConPort,
                                                                           javax.management.MBeanServer mbs,
                                                                           java.util.Map mapEnv)

Start a JMXConnectorServer. This method is used to expose the specified MBeanServer to external agents (such as JConsole) using RMI.

This method also allows for the RMI functionality to emulate the JConsole remote connection security.

For the list of relevant system properties please see: Java 1.6 Agent Documentation.

Parameters:

sHost - host to bind to

nRegPort - port used for the JMX RMI registry

nConPort - port used for the JMX RMI connection

mbs - MBeanServer that contains Coherence MBeans

mapEnv - a set of attributes to control the new connector server's behavior

Returns:

a JMXConnectorServer that has been started

See Also:

JMXConnectorServerFactory

startHttpConnector

public static java.lang.Object startHttpConnector(int nPort,
                                                  javax.management.MBeanServer mbs)

Start a com.sun.jdmk.comm.HtmlAdaptorServer, which is a part of the Sun JMX reference implementation. It is being created via reflection to avoid a runtime dependency to this library.

Parameters:

nPort - port to bind the HTTP server to

mbs - MBeanServer that this HTTP server will expose

Returns:

an HtmlAdaptorServer that has been started

quote

public static java.lang.String quote(java.lang.String s)

Create an escape-sequence string that allows for special characters to be included in a JMX ObjectName.

Parameters:

s - the string to be quoted

Returns:

the quoted string

Since:

Coherence 3.4

unquote

public static java.lang.String unquote(java.lang.String s)

Convert a string returned from the quote(java.lang.String) method to the original string.

Parameters:

s - the string to be unquoted

Returns:

the unquoted string

Throws:

java.lang.IllegalArgumentException - if the passed string could not have been returned by the quote(java.lang.String) method; for instance if it does not begin and end with a quote (")

Since:

Coherence 3.4

isQuoteRequired

public static boolean isQuoteRequired(java.lang.String s)

Determine if the string requires quotes.

Parameters:

s - the string to be quoted

Returns:

true iff the quote(java.lang.String) method needs to be called

Since:

Coherence 3.4

quoteCanonical

public static java.lang.String quoteCanonical(java.lang.String sCanonical)
                                       throws javax.management.MalformedObjectNameException

Return a quoted KeyPropertyString or a quoted canonical name.

Parameters:

sCanonical - a string to be quoted

Returns:

a quoted and escape-sequence string

Throws:

javax.management.MalformedObjectNameException - if the name is invalid

Since:

Coherence 3.4

hasDomain

public static boolean hasDomain(java.lang.String sCanonical)

Return true if the Canonical name is prefixed with the domain name.

Parameters:

sCanonical - a canonical MBean name or key property list

Returns:

true iff the name contains the domain prefix

Since:

Coherence 3.6

stripDomain

public static java.lang.String stripDomain(java.lang.String sCanonical)

Remove the domain prefix from the canonical name if one exists.

Parameters:

sCanonical - a canonical MBean name or key property list

Returns:

the canonical name stripped of the domain prefix

Since:

Coherence 3.6

compareKeyList

public static int compareKeyList(javax.management.ObjectName oname1,
                                 javax.management.ObjectName oname2)

Compare two global MBean names forcing numeric comparison of the node ID while using string comparison on all other key properties. For example, the following order is enforced:

   Coherence:type=Node,nodeId=2 < Coherence:type=Node,nodeId=10
   Coherence:type=Cache,nodeId=20 < Coherence:type=Node,nodeId=1
 

If the key sets are different the lexicographical comparison is used.

Parameters:

oname1 - the first ObjectName to be compared

oname2 - the second ObjectName to be compared

Returns:

a negative integer, zero, or a positive integer as the first name is less than, equal to, or greater than the second one

Since:

Coherence 3.6

getDescription

public static java.lang.String getDescription(java.lang.Class clzMBeanIface,
                                              javax.management.MBeanInfo info)

Retrieve the description for the MBean from the MBean interface annotation.

Parameters:

clzMBeanIface - the MBean interface

info - the MBeanInfo for the MBean

Returns:

the MBean description

Since:

Coherence 12.1.2

getDescription

public static java.lang.String getDescription(java.lang.Class clzMBeanIface,
                                              javax.management.MBeanAttributeInfo info)

Retrieve a description for a particular attribute by finding a Description annotation on the getter method for the attribute. If a description is not found on the getter method, the setter will be checked.

Parameters:

clzMBeanIface - the MBean interface

info - the MBeanAttributeInfo for the attribute

Returns:

the description for an attribute

Since:

Coherence 12.1.2

getDescription

public static java.lang.String getDescription(java.lang.Class clzMBeanIface,
                                              javax.management.MBeanOperationInfo info)

Retrieve a description for the particular MBeanOperationInfo by finding a Description annotation on the corresponding method.

Parameters:

clzMBeanIface - the MBean interface

info - the MBeanOperationInfo

Returns:

the description for an operation

Since:

Coherence 12.1.2

getParameterName

public static java.lang.String getParameterName(java.lang.Class clzMBeanIface,
                                                javax.management.MBeanOperationInfo infoOp,
                                                javax.management.MBeanParameterInfo infoParam,
                                                int iParam)

Retrieve the parameter name for the specified parameter by finding a Description annotation on the corresponding method.

Parameters:

clzMBeanIface - the MBean interface

infoOp - the MBeanOperationInfo for the op

infoParam - the MBeanParameterInfo for the parameter

iParam - zero-based sequence number of the parameter

Returns:

the name to use for the given parameter

Since:

Coherence 12.1.2

getNotificationInfo

public static javax.management.MBeanNotificationInfo[] getNotificationInfo(java.lang.Class clzMBeanIface)

Return an MBeanNotificationInfo if a Notification annotation is present on the provided MBean interface.

Parameters:

clzMBeanIface - the MBean interface

Returns:

an array of MBeanNotificationInfo of size 0 or 1 based on the presence of a Notification annotation.

getParameterAnnotation

protected static java.lang.annotation.Annotation getParameterAnnotation(java.lang.reflect.Method meth,
                                                                        int iParam,
                                                                        java.lang.Class clzAnno)

Retrieve an Annotation for a parameter to a method.

Parameters:

meth - the Method

iParam - zero-based index of the parameter

clzAnno - the Annotation Class to be retrieved

Returns:

the annotation or null if no Annotation is found

findMethod

protected static java.lang.reflect.Method findMethod(java.lang.Class clzMBean,
                                                     javax.management.MBeanOperationInfo op)

Find a Method for the specified MBeanOperationInfo in the specified MBean class or interface.

Parameters:

clzMBean - the MBean class (interface)

op - the MBeanOperationInfo

Returns:

the Method or null if no method is found

findMethod

protected static java.lang.reflect.Method findMethod(java.lang.Class clz,
                                                     java.lang.String sName,
                                                     java.lang.String[] asParamTypes)

Find a Method with the specified name and parameter types in the specified class.

Parameters:

clz - the class (interface)

sName - the Method name

asParamTypes - the array of Strings representing parameter types

Returns:

the Method or null if no method is found

Skip navigation links