activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1428950 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/DurableSubscriberNonPersistentMessageTest.java
Date Fri, 04 Jan 2013 16:11:54 GMT
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);



Mime
View raw message