You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2013/02/26 20:54:55 UTC
svn commit: r1450378 - in
/activemq/trunk/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp:
StompTest.java StompTestSupport.java
Author: tabish
Date: Tue Feb 26 19:54:55 2013
New Revision: 1450378
URL: http://svn.apache.org/r1450378
Log:
Move a couple methods into the test support class.
Modified:
activemq/trunk/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTest.java
activemq/trunk/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTestSupport.java
Modified: activemq/trunk/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTest.java?rev=1450378&r1=1450377&r2=1450378&view=diff
==============================================================================
--- activemq/trunk/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTest.java (original)
+++ activemq/trunk/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTest.java Tue Feb 26 19:54:55 2013
@@ -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 StompTest
}
}
- 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()
{
Modified: activemq/trunk/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTestSupport.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTestSupport.java?rev=1450378&r1=1450377&r2=1450378&view=diff
==============================================================================
--- activemq/trunk/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTestSupport.java (original)
+++ activemq/trunk/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTestSupport.java Tue Feb 26 19:54:55 2013
@@ -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;
+ }
+
}