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

use default amq persistence 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@574646 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2007-09-11 17:38:56 +00:00
parent 696b34a01d
commit a98333a19a
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
activemq-core/src/test/java/org/apache/activemq/perf/InactiveDurableTopicTest.java
View File

@ -40,7 +40,7 @@ import org.apache.commons.logging.LogFactory;
public class InactiveDurableTopicTest extends TestCase { public class InactiveDurableTopicTest extends TestCase {
private static final transient Log LOG = LogFactory.getLog(InactiveDurableTopicTest.class); private static final transient Log LOG = LogFactory.getLog(InactiveDurableTopicTest.class);
private static final int MESSAGE_COUNT = 100000; private static final int MESSAGE_COUNT = 1000000;
private static final String DEFAULT_PASSWORD = ""; private static final String DEFAULT_PASSWORD = "";
private static final String USERNAME = "testuser"; private static final String USERNAME = "testuser";
private static final String CLIENTID = "mytestclient"; private static final String CLIENTID = "mytestclient";
@ -60,7 +60,7 @@ public class InactiveDurableTopicTest extends TestCase {
super.setUp(); super.setUp();
broker = new BrokerService(); broker = new BrokerService();
broker.setPersistenceAdapter(new KahaPersistenceAdapter()); //broker.setPersistenceAdapter(new KahaPersistenceAdapter());
/* /*
* JournalPersistenceAdapterFactory factory = new * JournalPersistenceAdapterFactory factory = new
* JournalPersistenceAdapterFactory(); * JournalPersistenceAdapterFactory();
@ -133,8 +133,8 @@ public class InactiveDurableTopicTest extends TestCase {
for (loop = 0; loop < MESSAGE_COUNT; loop++) { for (loop = 0; loop < MESSAGE_COUNT; loop++) {
msg.setInt("key2", loop); msg.setInt("key2", loop);
publisher.send(msg, DELIVERY_MODE, DELIVERY_PRIORITY, Message.DEFAULT_TIME_TO_LIVE); publisher.send(msg, DELIVERY_MODE, DELIVERY_PRIORITY, Message.DEFAULT_TIME_TO_LIVE);
if (loop % 500 == 0) { if (loop % 5000 == 0) {
LOG.debug("Sent " + loop + " messages"); LOG.info("Sent " + loop + " messages");
} }
} }
Assert.assertEquals(loop, MESSAGE_COUNT); Assert.assertEquals(loop, MESSAGE_COUNT);