Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix test case after changes in https://issues.apache.org/jira/browse/AMQ-4237 broke the test's MBean lookup 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1428983 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Timothy A. Bish 2013-01-04 17:02:29 +00:00
parent 8a6ebc20a3
commit 8e9896825f
1 changed files with 1 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
activemq-core/src/test/java/org/apache/activemq/usecases/JMXRemoveQueueThenSendIgnoredTest.java
View File

@ -28,12 +28,7 @@ import javax.jms.QueueConnection;
import javax.jms.QueueSession; import javax.jms.QueueSession;
import javax.jms.Session; import javax.jms.Session;
import javax.jms.TextMessage; import javax.jms.TextMessage;
import javax.management.MBeanServerConnection;
import javax.management.MBeanServerInvocationHandler;
import javax.management.ObjectName; import javax.management.ObjectName;
import javax.management.remote.JMXConnector;
import javax.management.remote.JMXConnectorFactory;
import javax.management.remote.JMXServiceURL;
import org.apache.activemq.ActiveMQConnectionFactory; import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.broker.BrokerService; import org.apache.activemq.broker.BrokerService;
@ -132,7 +127,7 @@ public class JMXRemoveQueueThenSendIgnoredTest {
private int numberOfMessages() throws Exception { private int numberOfMessages() throws Exception {
ObjectName queueViewMBeanName = new ObjectName( ObjectName queueViewMBeanName = new ObjectName(
domain + ":Type=Queue,Destination=myqueue,BrokerName=dev"); domain + ":destinationType=Queue,destinationName=myqueue,type=Broker,brokerName=dev");
QueueViewMBean queue = (QueueViewMBean) QueueViewMBean queue = (QueueViewMBean)
brokerService.getManagementContext().newProxyInstance(queueViewMBeanName, QueueViewMBean.class, true); brokerService.getManagementContext().newProxyInstance(queueViewMBeanName, QueueViewMBean.class, true);
long size = queue.getQueueSize(); long size = queue.getQueueSize();