svn commit: r1428950 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/DurableSubscriberNonPersistentMessageTest.java

[ta...@apache.org]

Author: tabish
Date: Fri Jan  4 16:11:54 2013
New Revision: 1428950

URL: http://svn.apache.org/viewvc?rev=1428950&view=rev
Log:
fix test case after changes in https://issues.apache.org/jira/browse/AMQ-4237 broke the test's MBean lookup

Modified:
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/DurableSubscriberNonPersistentMessageTest.java

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/DurableSubscriberNonPersistentMessageTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/DurableSubscriberNonPersistentMessageTest.java?rev=1428950&r1=1428949&r2=1428950&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/DurableSubscriberNonPersistentMessageTest.java (original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/DurableSubscriberNonPersistentMessageTest.java Fri Jan  4 16:11:54 2013
@@ -138,10 +138,12 @@ public class DurableSubscriberNonPersist
 
             createConsumer(interest, cleanupMsgCount);
 
-            String brokerVersion = (String) mbeanServer.getAttribute(new ObjectName("org.apache.activemq:BrokerName=localhost,Type=Broker"), "BrokerVersion");
+            String brokerVersion = (String) mbeanServer.getAttribute(new ObjectName("org.apache.activemq:brokerName=localhost,type=Broker"), "BrokerVersion");
 
             LOG.info("Test run on: " + brokerVersion);
-            final String theJmxObject = "org.apache.activemq:BrokerName=localhost,Type=Subscription,persistentMode=Durable,subscriptionID=MyDurableTopic,destinationType=Topic,destinationName=TEST,clientId=Jason";
+            final String theJmxObject = "org.apache.activemq:type=Broker,brokerName=localhost," +
+                    "endpoint=Consumer,destinationType=Topic,destinationName=TEST,clientId=Jason," +
+                    "consumerId=Durable(Jason_MyDurableTopic)";
 
             assertTrue("pendingQueueSize should be zero", Wait.waitFor(new Wait.Condition() {
                 @Override
@@ -275,10 +277,10 @@ public class DurableSubscriberNonPersist
 
     public class Consumer {
 
-        private ConnectionFactory factory;
-        private ActiveMQConnection connection;
-        private Session session;
-        private MessageConsumer messageConsumer;
+        private final ConnectionFactory factory;
+        private final ActiveMQConnection connection;
+        private final Session session;
+        private final MessageConsumer messageConsumer;
 
         public Consumer(String brokerURL, String interest, String clientId) throws JMSException {
             factory = new ActiveMQConnectionFactory(brokerURL);