AMQ-7132 - update RecoveryStatsBrokerTest back to using always journal sync but a...
authorChristopher L. Shannon (cshannon) <christopher.l.shannon@gmail.com>
Wed, 16 Jan 2019 18:52:38 +0000 (13:52 -0500)
committerChristopher L. Shannon (cshannon) <christopher.l.shannon@gmail.com>
Wed, 16 Jan 2019 18:52:52 +0000 (13:52 -0500)
activemq-unit-tests/src/test/java/org/apache/activemq/broker/RecoveryStatsBrokerTest.java

index b227218..c143863 100644 (file)
@@ -61,8 +61,7 @@ public class RecoveryStatsBrokerTest extends BrokerRestartTestSupport {
     @Override
     protected void configureBroker(BrokerService broker) throws Exception {
         KahaDBPersistenceAdapter persistenceAdapter = new KahaDBPersistenceAdapter();
-        persistenceAdapter.setJournalMaxFileLength(1024*1024);
-        persistenceAdapter.setJournalDiskSyncStrategy(JournalDiskSyncStrategy.PERIODIC.name());
+        persistenceAdapter.setJournalMaxFileLength(1024*20);
         //persistenceAdapter.setConcurrentStoreAndDispatchQueues(false);
         persistenceAdapter.setDirectory(broker.getBrokerDataDirectory());
         broker.setPersistenceAdapter(persistenceAdapter);
@@ -138,7 +137,7 @@ public class RecoveryStatsBrokerTest extends BrokerRestartTestSupport {
 
         destinations.forEach(destination -> consumedMessages.put(destination, 0));
 
-        int numberOfMessages = 10000;
+        int numberOfMessages = 400;
 
         StubConnection connection = createConnection();
         ConnectionInfo connectionInfo = createConnectionInfo();