svn commit: r574646 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/InactiveDurableTopicTest.java

[rajdavies]

Author: rajdavies
Date: Tue Sep 11 10:38:56 2007
New Revision: 574646

URL: http://svn.apache.org/viewvc?rev=574646&view=rev
Log:
use default amq persistence

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=574646&r1=574645&r2=574646&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
 Tue Sep 11 10:38:56 2007
@@ -40,7 +40,7 @@
 public class InactiveDurableTopicTest extends TestCase {
     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 USERNAME = "testuser";
     private static final String CLIENTID = "mytestclient";
@@ -60,7 +60,7 @@
         super.setUp();
         broker = new BrokerService();
 
-        broker.setPersistenceAdapter(new KahaPersistenceAdapter());
+        //broker.setPersistenceAdapter(new KahaPersistenceAdapter());
         /*
          * JournalPersistenceAdapterFactory factory = new
          * JournalPersistenceAdapterFactory();
@@ -133,8 +133,8 @@
             for (loop = 0; loop < MESSAGE_COUNT; loop++) {
                 msg.setInt("key2", loop);
                 publisher.send(msg, DELIVERY_MODE, DELIVERY_PRIORITY, 
Message.DEFAULT_TIME_TO_LIVE);
-                if (loop % 500 == 0) {
-                    LOG.debug("Sent " + loop + " messages");
+                if (loop % 5000 == 0) {
+                    LOG.info("Sent " + loop + " messages");
                 }
             }
             Assert.assertEquals(loop, MESSAGE_COUNT);