diff --git a/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTest.java b/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTest.java index 52962ce65c..e25e135e95 100644 --- a/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTest.java +++ b/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTest.java @@ -43,7 +43,6 @@ import javax.jms.MessageProducer; import javax.jms.ObjectMessage; import javax.jms.Session; import javax.jms.TextMessage; -import javax.management.MalformedObjectNameException; import javax.management.ObjectName; import org.apache.activemq.broker.TransportConnector; @@ -2166,21 +2165,6 @@ public class StompTest extends StompTestSupport { } } - private BrokerViewMBean getProxyToBroker() throws MalformedObjectNameException, JMSException { - ObjectName brokerViewMBean = new ObjectName( - "org.apache.activemq:type=Broker,brokerName=localhost"); - BrokerViewMBean proxy = (BrokerViewMBean) brokerService.getManagementContext() - .newProxyInstance(brokerViewMBean, BrokerViewMBean.class, true); - return proxy; - } - - private QueueViewMBean getProxyToQueue(String name) throws MalformedObjectNameException, JMSException { - ObjectName queueViewMBeanName = new ObjectName("org.apache.activemq:type=Broker,brokerName=localhost,destinationType=Queue,destinationName="+name); - QueueViewMBean proxy = (QueueViewMBean) brokerService.getManagementContext() - .newProxyInstance(queueViewMBeanName, QueueViewMBean.class, true); - return proxy; - } - protected void assertClients(final int expected) throws Exception { Wait.waitFor(new Wait.Condition() { diff --git a/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTestSupport.java b/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTestSupport.java index 960f23b0d3..ad816a6f05 100644 --- a/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTestSupport.java +++ b/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTestSupport.java @@ -24,11 +24,17 @@ import java.security.ProtectionDomain; import java.util.ArrayList; import java.util.List; +import javax.jms.JMSException; +import javax.management.MalformedObjectNameException; +import javax.management.ObjectName; + import org.apache.activemq.ActiveMQConnectionFactory; import org.apache.activemq.AutoFailTestSupport; import org.apache.activemq.broker.BrokerPlugin; import org.apache.activemq.broker.BrokerService; import org.apache.activemq.broker.TransportConnector; +import org.apache.activemq.broker.jmx.BrokerViewMBean; +import org.apache.activemq.broker.jmx.QueueViewMBean; import org.apache.activemq.filter.DestinationMapEntry; import org.apache.activemq.security.AuthenticationUser; import org.apache.activemq.security.AuthorizationEntry; @@ -282,4 +288,27 @@ public class StompTestSupport { stompConnection = null; } } + + protected BrokerViewMBean getProxyToBroker() throws MalformedObjectNameException, JMSException { + ObjectName brokerViewMBean = new ObjectName( + "org.apache.activemq:type=Broker,brokerName=localhost"); + BrokerViewMBean proxy = (BrokerViewMBean) brokerService.getManagementContext() + .newProxyInstance(brokerViewMBean, BrokerViewMBean.class, true); + return proxy; + } + + protected QueueViewMBean getProxyToQueue(String name) throws MalformedObjectNameException, JMSException { + ObjectName queueViewMBeanName = new ObjectName("org.apache.activemq:type=Broker,brokerName=localhost,destinationType=Queue,destinationName="+name); + QueueViewMBean proxy = (QueueViewMBean) brokerService.getManagementContext() + .newProxyInstance(queueViewMBeanName, QueueViewMBean.class, true); + return proxy; + } + + protected QueueViewMBean getProxyToTopic(String name) throws MalformedObjectNameException, JMSException { + ObjectName queueViewMBeanName = new ObjectName("org.apache.activemq:type=Broker,brokerName=localhost,destinationType=Topic,destinationName="+name); + QueueViewMBean proxy = (QueueViewMBean) brokerService.getManagementContext() + .newProxyInstance(queueViewMBeanName, QueueViewMBean.class, true); + return proxy; + } + }