You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ra...@apache.org on 2010/06/16 11:42:32 UTC
svn commit: r955171 -
/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/InactiveDurableTopicTest.java
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();