diff --git a/org.springframework.integration.jmx/src/test/java/org/springframework/integration/jmx/config/ControlBusParserTests.java b/org.springframework.integration.jmx/src/test/java/org/springframework/integration/jmx/config/ControlBusParserTests.java index c81f76c8e3..2b6a7ec99d 100644 --- a/org.springframework.integration.jmx/src/test/java/org/springframework/integration/jmx/config/ControlBusParserTests.java +++ b/org.springframework.integration.jmx/src/test/java/org/springframework/integration/jmx/config/ControlBusParserTests.java @@ -18,12 +18,16 @@ package org.springframework.integration.jmx.config; import static org.junit.Assert.assertEquals; +import javax.management.MBeanServer; + import org.junit.Test; import org.junit.runner.RunWith; +import org.springframework.beans.DirectFieldAccessor; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.ApplicationContext; import org.springframework.integration.control.ControlBus; +import org.springframework.jmx.export.MBeanExporter; import org.springframework.test.context.ContextConfiguration; import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; @@ -43,6 +47,10 @@ public class ControlBusParserTests { public void test() throws InterruptedException { ControlBus controlBus = this.context.getBean("controlBus", ControlBus.class); assertEquals(controlBus.getOperationChannel(), this.context.getBean("testChannel")); + MBeanServer server = this.context.getBean("mbs", MBeanServer.class); + MBeanExporter exporter = (MBeanExporter) new DirectFieldAccessor(controlBus).getPropertyValue("exporter"); + assertEquals(server, exporter.getServer()); + exporter.destroy(); } }