MBeanExporter silently ignores null beans
Issue: SPR-15031
This commit is contained in:
parent
e0c43c4fcb
commit
9c55d22f78
|
@ -83,7 +83,7 @@ import org.springframework.util.ObjectUtils;
|
||||||
* via the {@link #setListeners(MBeanExporterListener[]) listeners} property, allowing
|
* via the {@link #setListeners(MBeanExporterListener[]) listeners} property, allowing
|
||||||
* application code to be notified of MBean registration and unregistration events.
|
* application code to be notified of MBean registration and unregistration events.
|
||||||
*
|
*
|
||||||
* <p>This exporter is compatible with MBeans and MXBeans on Java 6 and above.
|
* <p>This exporter is compatible with MBeans as well as MXBeans.
|
||||||
*
|
*
|
||||||
* @author Rob Harrop
|
* @author Rob Harrop
|
||||||
* @author Juergen Hoeller
|
* @author Juergen Hoeller
|
||||||
|
@ -466,7 +466,7 @@ public class MBeanExporter extends MBeanRegistrationSupport implements MBeanExpo
|
||||||
objectName = JmxUtils.appendIdentityToObjectName(objectName, managedResource);
|
objectName = JmxUtils.appendIdentityToObjectName(objectName, managedResource);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (Exception ex) {
|
catch (Throwable ex) {
|
||||||
throw new MBeanExportException("Unable to generate ObjectName for MBean [" + managedResource + "]", ex);
|
throw new MBeanExportException("Unable to generate ObjectName for MBean [" + managedResource + "]", ex);
|
||||||
}
|
}
|
||||||
registerManagedResource(managedResource, objectName);
|
registerManagedResource(managedResource, objectName);
|
||||||
|
@ -578,7 +578,8 @@ public class MBeanExporter extends MBeanRegistrationSupport implements MBeanExpo
|
||||||
* @param mapValue the value configured for this bean in the beans map;
|
* @param mapValue the value configured for this bean in the beans map;
|
||||||
* may be either the {@code String} name of a bean, or the bean itself
|
* may be either the {@code String} name of a bean, or the bean itself
|
||||||
* @param beanKey the key associated with this bean in the beans map
|
* @param beanKey the key associated with this bean in the beans map
|
||||||
* @return the {@code ObjectName} under which the resource was registered
|
* @return the {@code ObjectName} under which the resource was registered,
|
||||||
|
* or {@code null} if the actual resource was {@code null} as well
|
||||||
* @throws MBeanExportException if the export failed
|
* @throws MBeanExportException if the export failed
|
||||||
* @see #setBeans
|
* @see #setBeans
|
||||||
* @see #registerBeanInstance
|
* @see #registerBeanInstance
|
||||||
|
@ -599,12 +600,14 @@ public class MBeanExporter extends MBeanRegistrationSupport implements MBeanExpo
|
||||||
}
|
}
|
||||||
else {
|
else {
|
||||||
Object bean = this.beanFactory.getBean(beanName);
|
Object bean = this.beanFactory.getBean(beanName);
|
||||||
ObjectName objectName = registerBeanInstance(bean, beanKey);
|
if (bean != null) {
|
||||||
replaceNotificationListenerBeanNameKeysIfNecessary(beanName, objectName);
|
ObjectName objectName = registerBeanInstance(bean, beanKey);
|
||||||
return objectName;
|
replaceNotificationListenerBeanNameKeysIfNecessary(beanName, objectName);
|
||||||
|
return objectName;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
else {
|
else if (mapValue != null) {
|
||||||
// Plain bean instance -> register it directly.
|
// Plain bean instance -> register it directly.
|
||||||
if (this.beanFactory != null) {
|
if (this.beanFactory != null) {
|
||||||
Map<String, ?> beansOfSameType =
|
Map<String, ?> beansOfSameType =
|
||||||
|
@ -621,10 +624,11 @@ public class MBeanExporter extends MBeanRegistrationSupport implements MBeanExpo
|
||||||
return registerBeanInstance(mapValue, beanKey);
|
return registerBeanInstance(mapValue, beanKey);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (Exception ex) {
|
catch (Throwable ex) {
|
||||||
throw new UnableToRegisterMBeanException(
|
throw new UnableToRegisterMBeanException(
|
||||||
"Unable to register MBean [" + mapValue + "] with key '" + beanKey + "'", ex);
|
"Unable to register MBean [" + mapValue + "] with key '" + beanKey + "'", ex);
|
||||||
}
|
}
|
||||||
|
return null;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@ -816,7 +820,7 @@ public class MBeanExporter extends MBeanRegistrationSupport implements MBeanExpo
|
||||||
mbean.setManagedResource(managedResource, MR_TYPE_OBJECT_REFERENCE);
|
mbean.setManagedResource(managedResource, MR_TYPE_OBJECT_REFERENCE);
|
||||||
return mbean;
|
return mbean;
|
||||||
}
|
}
|
||||||
catch (Exception ex) {
|
catch (Throwable ex) {
|
||||||
throw new MBeanExportException("Could not create ModelMBean for managed resource [" +
|
throw new MBeanExportException("Could not create ModelMBean for managed resource [" +
|
||||||
managedResource + "] with key '" + beanKey + "'", ex);
|
managedResource + "] with key '" + beanKey + "'", ex);
|
||||||
}
|
}
|
||||||
|
@ -984,7 +988,7 @@ public class MBeanExporter extends MBeanRegistrationSupport implements MBeanExpo
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (Exception ex) {
|
catch (Throwable ex) {
|
||||||
throw new MBeanExportException("Unable to register NotificationListener", ex);
|
throw new MBeanExportException("Unable to register NotificationListener", ex);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -1004,7 +1008,7 @@ public class MBeanExporter extends MBeanRegistrationSupport implements MBeanExpo
|
||||||
this.server.removeNotificationListener(mappedObjectName, bean.getNotificationListener(),
|
this.server.removeNotificationListener(mappedObjectName, bean.getNotificationListener(),
|
||||||
bean.getNotificationFilter(), bean.getHandback());
|
bean.getNotificationFilter(), bean.getHandback());
|
||||||
}
|
}
|
||||||
catch (Exception ex) {
|
catch (Throwable ex) {
|
||||||
if (logger.isDebugEnabled()) {
|
if (logger.isDebugEnabled()) {
|
||||||
logger.debug("Unable to unregister NotificationListener", ex);
|
logger.debug("Unable to unregister NotificationListener", ex);
|
||||||
}
|
}
|
||||||
|
|
|
@ -39,8 +39,10 @@ import org.junit.Test;
|
||||||
import org.junit.rules.ExpectedException;
|
import org.junit.rules.ExpectedException;
|
||||||
|
|
||||||
import org.springframework.aop.framework.ProxyFactory;
|
import org.springframework.aop.framework.ProxyFactory;
|
||||||
|
import org.springframework.beans.factory.FactoryBean;
|
||||||
import org.springframework.beans.factory.support.BeanDefinitionBuilder;
|
import org.springframework.beans.factory.support.BeanDefinitionBuilder;
|
||||||
import org.springframework.beans.factory.support.DefaultListableBeanFactory;
|
import org.springframework.beans.factory.support.DefaultListableBeanFactory;
|
||||||
|
import org.springframework.beans.factory.support.RootBeanDefinition;
|
||||||
import org.springframework.context.ConfigurableApplicationContext;
|
import org.springframework.context.ConfigurableApplicationContext;
|
||||||
import org.springframework.context.support.ClassPathXmlApplicationContext;
|
import org.springframework.context.support.ClassPathXmlApplicationContext;
|
||||||
import org.springframework.jmx.AbstractMBeanServerTests;
|
import org.springframework.jmx.AbstractMBeanServerTests;
|
||||||
|
@ -68,7 +70,6 @@ import static org.junit.Assert.*;
|
||||||
* @author Sam Brannen
|
* @author Sam Brannen
|
||||||
* @author Stephane Nicoll
|
* @author Stephane Nicoll
|
||||||
*/
|
*/
|
||||||
@SuppressWarnings("deprecation")
|
|
||||||
public class MBeanExporterTests extends AbstractMBeanServerTests {
|
public class MBeanExporterTests extends AbstractMBeanServerTests {
|
||||||
|
|
||||||
@Rule
|
@Rule
|
||||||
|
@ -235,7 +236,6 @@ public class MBeanExporterTests extends AbstractMBeanServerTests {
|
||||||
assertListener(listener2);
|
assertListener(listener2);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
public void testExportJdkProxy() throws Exception {
|
public void testExportJdkProxy() throws Exception {
|
||||||
JmxTestBean bean = new JmxTestBean();
|
JmxTestBean bean = new JmxTestBean();
|
||||||
|
@ -541,10 +541,7 @@ public class MBeanExporterTests extends AbstractMBeanServerTests {
|
||||||
start(exporter);
|
start(exporter);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
@Test // SPR-2158
|
||||||
* SPR-2158
|
|
||||||
*/
|
|
||||||
@Test
|
|
||||||
public void testMBeanIsNotUnregisteredSpuriouslyIfSomeExternalProcessHasUnregisteredMBean() throws Exception {
|
public void testMBeanIsNotUnregisteredSpuriouslyIfSomeExternalProcessHasUnregisteredMBean() throws Exception {
|
||||||
MBeanExporter exporter = new MBeanExporter();
|
MBeanExporter exporter = new MBeanExporter();
|
||||||
exporter.setBeans(getBeanMap());
|
exporter.setBeans(getBeanMap());
|
||||||
|
@ -561,10 +558,7 @@ public class MBeanExporterTests extends AbstractMBeanServerTests {
|
||||||
listener.getUnregistered().size());
|
listener.getUnregistered().size());
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
@Test // SPR-3302
|
||||||
* SPR-3302
|
|
||||||
*/
|
|
||||||
@Test
|
|
||||||
public void testBeanNameCanBeUsedInNotificationListenersMap() throws Exception {
|
public void testBeanNameCanBeUsedInNotificationListenersMap() throws Exception {
|
||||||
String beanName = "charlesDexterWard";
|
String beanName = "charlesDexterWard";
|
||||||
BeanDefinitionBuilder testBean = BeanDefinitionBuilder.rootBeanDefinition(JmxTestBean.class);
|
BeanDefinitionBuilder testBean = BeanDefinitionBuilder.rootBeanDefinition(JmxTestBean.class);
|
||||||
|
@ -608,10 +602,7 @@ public class MBeanExporterTests extends AbstractMBeanServerTests {
|
||||||
start(exporter);
|
start(exporter);
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
@Test // SPR-3625
|
||||||
* SPR-3625
|
|
||||||
*/
|
|
||||||
@Test
|
|
||||||
public void testMBeanIsUnregisteredForRuntimeExceptionDuringInitialization() throws Exception {
|
public void testMBeanIsUnregisteredForRuntimeExceptionDuringInitialization() throws Exception {
|
||||||
BeanDefinitionBuilder builder1 = BeanDefinitionBuilder.rootBeanDefinition(Person.class);
|
BeanDefinitionBuilder builder1 = BeanDefinitionBuilder.rootBeanDefinition(Person.class);
|
||||||
BeanDefinitionBuilder builder2 = BeanDefinitionBuilder
|
BeanDefinitionBuilder builder2 = BeanDefinitionBuilder
|
||||||
|
@ -667,6 +658,37 @@ public class MBeanExporterTests extends AbstractMBeanServerTests {
|
||||||
ObjectNameManager.getInstance(secondBeanName));
|
ObjectNameManager.getInstance(secondBeanName));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testRegisterFactoryBean() throws MalformedObjectNameException {
|
||||||
|
DefaultListableBeanFactory factory = new DefaultListableBeanFactory();
|
||||||
|
factory.registerBeanDefinition("spring:type=FactoryBean", new RootBeanDefinition(ProperSomethingFactoryBean.class));
|
||||||
|
|
||||||
|
MBeanExporter exporter = new MBeanExporter();
|
||||||
|
exporter.setServer(getServer());
|
||||||
|
exporter.setBeanFactory(factory);
|
||||||
|
exporter.setAutodetectMode(MBeanExporter.AUTODETECT_ALL);
|
||||||
|
|
||||||
|
start(exporter);
|
||||||
|
assertIsRegistered("Non-null FactoryBean object registered",
|
||||||
|
ObjectNameManager.getInstance("spring:type=FactoryBean"));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testIgnoreNullObjectFromFactoryBean() throws MalformedObjectNameException {
|
||||||
|
DefaultListableBeanFactory factory = new DefaultListableBeanFactory();
|
||||||
|
factory.registerBeanDefinition("spring:type=FactoryBean", new RootBeanDefinition(NullSomethingFactoryBean.class));
|
||||||
|
|
||||||
|
MBeanExporter exporter = new MBeanExporter();
|
||||||
|
exporter.setServer(getServer());
|
||||||
|
exporter.setBeanFactory(factory);
|
||||||
|
exporter.setAutodetectMode(MBeanExporter.AUTODETECT_ALL);
|
||||||
|
|
||||||
|
start(exporter);
|
||||||
|
assertIsNotRegistered("Null FactoryBean object not registered",
|
||||||
|
ObjectNameManager.getInstance("spring:type=FactoryBean"));
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
private ConfigurableApplicationContext load(String context) {
|
private ConfigurableApplicationContext load(String context) {
|
||||||
return new ClassPathXmlApplicationContext(context, getClass());
|
return new ClassPathXmlApplicationContext(context, getClass());
|
||||||
}
|
}
|
||||||
|
@ -799,4 +821,41 @@ public class MBeanExporterTests extends AbstractMBeanServerTests {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
public interface SomethingMBean {}
|
||||||
|
|
||||||
|
public static class Something implements SomethingMBean {}
|
||||||
|
|
||||||
|
|
||||||
|
public static class ProperSomethingFactoryBean implements FactoryBean<Something> {
|
||||||
|
|
||||||
|
@Override public Something getObject() {
|
||||||
|
return new Something();
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override public Class<?> getObjectType() {
|
||||||
|
return Something.class;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override public boolean isSingleton() {
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
public static class NullSomethingFactoryBean implements FactoryBean<Something> {
|
||||||
|
|
||||||
|
@Override public Something getObject() {
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override public Class<?> getObjectType() {
|
||||||
|
return Something.class;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override public boolean isSingleton() {
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue