/*
 * Copyright 2002-2017 the original author or authors.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.springframework.jmx.support;

import javax.management.MBeanServer;
import javax.management.MBeanServerFactory;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import org.springframework.beans.factory.DisposableBean;
import org.springframework.beans.factory.FactoryBean;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.jmx.MBeanServerNotFoundException;
import org.springframework.lang.Nullable;

FactoryBean that obtains an MBeanServer reference through the standard JMX 1.2 MBeanServerFactory API (which is available on JDK 1.5 or as part of a JMX 1.2 provider). Exposes the MBeanServer for bean references.

By default, MBeanServerFactoryBean will always create a new MBeanServer even if one is already running. To have the MBeanServerFactoryBean attempt to locate a running MBeanServer first, set the value of the "locateExistingServerIfPossible" property to "true".

Author:Rob Harrop, Juergen Hoeller
See Also:
Since:1.2
/** * {@link FactoryBean} that obtains an {@link javax.management.MBeanServer} reference * through the standard JMX 1.2 {@link javax.management.MBeanServerFactory} * API (which is available on JDK 1.5 or as part of a JMX 1.2 provider). * Exposes the {@code MBeanServer} for bean references. * * <p>By default, {@code MBeanServerFactoryBean} will always create * a new {@code MBeanServer} even if one is already running. To have * the {@code MBeanServerFactoryBean} attempt to locate a running * {@code MBeanServer} first, set the value of the * "locateExistingServerIfPossible" property to "true". * * @author Rob Harrop * @author Juergen Hoeller * @since 1.2 * @see #setLocateExistingServerIfPossible * @see #locateMBeanServer * @see javax.management.MBeanServer * @see javax.management.MBeanServerFactory#findMBeanServer * @see javax.management.MBeanServerFactory#createMBeanServer * @see javax.management.MBeanServerFactory#newMBeanServer * @see MBeanServerConnectionFactoryBean * @see ConnectorServerFactoryBean */
public class MBeanServerFactoryBean implements FactoryBean<MBeanServer>, InitializingBean, DisposableBean { protected final Log logger = LogFactory.getLog(getClass()); private boolean locateExistingServerIfPossible = false; @Nullable private String agentId; @Nullable private String defaultDomain; private boolean registerWithFactory = true; @Nullable private MBeanServer server; private boolean newlyRegistered = false;
Set whether or not the MBeanServerFactoryBean should attempt to locate a running MBeanServer before creating one.

Default is false.

/** * Set whether or not the {@code MBeanServerFactoryBean} should attempt * to locate a running {@code MBeanServer} before creating one. * <p>Default is {@code false}. */
public void setLocateExistingServerIfPossible(boolean locateExistingServerIfPossible) { this.locateExistingServerIfPossible = locateExistingServerIfPossible; }
Set the agent id of the MBeanServer to locate.

Default is none. If specified, this will result in an automatic attempt being made to locate the attendant MBeanServer, and (importantly) if said MBeanServer cannot be located no attempt will be made to create a new MBeanServer (and an MBeanServerNotFoundException will be thrown at resolution time).

Specifying the empty String indicates the platform MBeanServer.

See Also:
/** * Set the agent id of the {@code MBeanServer} to locate. * <p>Default is none. If specified, this will result in an * automatic attempt being made to locate the attendant MBeanServer, * and (importantly) if said MBeanServer cannot be located no * attempt will be made to create a new MBeanServer (and an * MBeanServerNotFoundException will be thrown at resolution time). * <p>Specifying the empty String indicates the platform MBeanServer. * @see javax.management.MBeanServerFactory#findMBeanServer(String) */
public void setAgentId(String agentId) { this.agentId = agentId; }
Set the default domain to be used by the MBeanServer, to be passed to MBeanServerFactory.createMBeanServer() or MBeanServerFactory.findMBeanServer().

Default is none.

See Also:
/** * Set the default domain to be used by the {@code MBeanServer}, * to be passed to {@code MBeanServerFactory.createMBeanServer()} * or {@code MBeanServerFactory.findMBeanServer()}. * <p>Default is none. * @see javax.management.MBeanServerFactory#createMBeanServer(String) * @see javax.management.MBeanServerFactory#findMBeanServer(String) */
public void setDefaultDomain(String defaultDomain) { this.defaultDomain = defaultDomain; }
Set whether to register the MBeanServer with the MBeanServerFactory, making it available through MBeanServerFactory.findMBeanServer().
See Also:
/** * Set whether to register the {@code MBeanServer} with the * {@code MBeanServerFactory}, making it available through * {@code MBeanServerFactory.findMBeanServer()}. * @see javax.management.MBeanServerFactory#createMBeanServer * @see javax.management.MBeanServerFactory#findMBeanServer */
public void setRegisterWithFactory(boolean registerWithFactory) { this.registerWithFactory = registerWithFactory; }
Creates the MBeanServer instance.
/** * Creates the {@code MBeanServer} instance. */
@Override public void afterPropertiesSet() throws MBeanServerNotFoundException { // Try to locate existing MBeanServer, if desired. if (this.locateExistingServerIfPossible || this.agentId != null) { try { this.server = locateMBeanServer(this.agentId); } catch (MBeanServerNotFoundException ex) { // If agentId was specified, we were only supposed to locate that // specific MBeanServer; so let's bail if we can't find it. if (this.agentId != null) { throw ex; } logger.debug("No existing MBeanServer found - creating new one"); } } // Create a new MBeanServer and register it, if desired. if (this.server == null) { this.server = createMBeanServer(this.defaultDomain, this.registerWithFactory); this.newlyRegistered = this.registerWithFactory; } }
Attempt to locate an existing MBeanServer. Called if locateExistingServerIfPossible is set to true.

The default implementation attempts to find an MBeanServer using a standard lookup. Subclasses may override to add additional location logic.

Params:
  • agentId – the agent identifier of the MBeanServer to retrieve. If this parameter is null, all registered MBeanServers are considered.
Throws:
See Also:
Returns:the MBeanServer if found
/** * Attempt to locate an existing {@code MBeanServer}. * Called if {@code locateExistingServerIfPossible} is set to {@code true}. * <p>The default implementation attempts to find an {@code MBeanServer} using * a standard lookup. Subclasses may override to add additional location logic. * @param agentId the agent identifier of the MBeanServer to retrieve. * If this parameter is {@code null}, all registered MBeanServers are * considered. * @return the {@code MBeanServer} if found * @throws org.springframework.jmx.MBeanServerNotFoundException * if no {@code MBeanServer} could be found * @see #setLocateExistingServerIfPossible * @see JmxUtils#locateMBeanServer(String) * @see javax.management.MBeanServerFactory#findMBeanServer(String) */
protected MBeanServer locateMBeanServer(@Nullable String agentId) throws MBeanServerNotFoundException { return JmxUtils.locateMBeanServer(agentId); }
Create a new MBeanServer instance and register it with the MBeanServerFactory, if desired.
Params:
  • defaultDomain – the default domain, or null if none
  • registerWithFactory – whether to register the MBeanServer with the MBeanServerFactory
See Also:
/** * Create a new {@code MBeanServer} instance and register it with the * {@code MBeanServerFactory}, if desired. * @param defaultDomain the default domain, or {@code null} if none * @param registerWithFactory whether to register the {@code MBeanServer} * with the {@code MBeanServerFactory} * @see javax.management.MBeanServerFactory#createMBeanServer * @see javax.management.MBeanServerFactory#newMBeanServer */
protected MBeanServer createMBeanServer(@Nullable String defaultDomain, boolean registerWithFactory) { if (registerWithFactory) { return MBeanServerFactory.createMBeanServer(defaultDomain); } else { return MBeanServerFactory.newMBeanServer(defaultDomain); } } @Override @Nullable public MBeanServer getObject() { return this.server; } @Override public Class<? extends MBeanServer> getObjectType() { return (this.server != null ? this.server.getClass() : MBeanServer.class); } @Override public boolean isSingleton() { return true; }
Unregisters the MBeanServer instance, if necessary.
/** * Unregisters the {@code MBeanServer} instance, if necessary. */
@Override public void destroy() { if (this.newlyRegistered) { MBeanServerFactory.releaseMBeanServer(this.server); } } }