activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r955171 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/InactiveDurableTopicTest.java
Date Wed, 16 Jun 2010 09:42:32 GMT
Author: rajdavies
Date: Wed Jun 16 09:42:32 2010
New Revision: 955171

URL: http://svn.apache.org/viewvc?rev=955171&view=rev
Log:
fixed incorrect broker URL

Modified:
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/InactiveDurableTopicTest.java

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/InactiveDurableTopicTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/InactiveDurableTopicTest.java?rev=955171&r1=955170&r2=955171&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/InactiveDurableTopicTest.java
(original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/InactiveDurableTopicTest.java
Wed Jun 16 09:42:32 2010
@@ -24,13 +24,11 @@ import javax.jms.MessageProducer;
 import javax.jms.Session;
 import javax.jms.Topic;
 import javax.jms.TopicSubscriber;
-
 import junit.framework.Assert;
 import junit.framework.AssertionFailedError;
 import junit.framework.TestCase;
 import org.apache.activemq.ActiveMQConnectionFactory;
 import org.apache.activemq.broker.BrokerService;
-import org.apache.activemq.store.kahadaptor.KahaPersistenceAdapter;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
@@ -56,6 +54,7 @@ public class InactiveDurableTopicTest ex
     private ActiveMQConnectionFactory connectionFactory;
     private BrokerService broker;
 
+    @Override
     protected void setUp() throws Exception {
         super.setUp();
         broker = new BrokerService();
@@ -68,7 +67,7 @@ public class InactiveDurableTopicTest ex
          * factory.setTaskRunnerFactory(broker.getTaskRunnerFactory());
          * factory.setUseJournal(false); broker.setPersistenceFactory(factory);
          */
-        broker.addConnector(ActiveMQConnectionFactory.DEFAULT_BROKER_URL);
+        broker.addConnector(ActiveMQConnectionFactory.DEFAULT_BROKER_BIND_URL);
         broker.start();
         connectionFactory = new ActiveMQConnectionFactory(ActiveMQConnectionFactory.DEFAULT_BROKER_URL);
         /*
@@ -79,6 +78,7 @@ public class InactiveDurableTopicTest ex
         connectionFactory.setUseAsyncSend(true);
     }
 
+    @Override
     protected void tearDown() throws Exception {
         super.tearDown();
         broker.stop();



Mime
View raw message