[activemq] branch master updated: AMQ-7132 - update RecoveryStatsBrokerTest back to using always journal sync but a smaller journal size and less test messages to speed up test

[cshannon]

This is an automated email from the ASF dual-hosted git repository.

cshannon pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq.git


The following commit(s) were added to refs/heads/master by this push:
     new 9fba7ec  AMQ-7132 - update RecoveryStatsBrokerTest back to using 
always journal sync but a smaller journal size and less test messages to speed 
up test
9fba7ec is described below

commit 9fba7ec352cba590666d8e2db08e404939ef729d
Author: Christopher L. Shannon (cshannon) <christopher.l.shan...@gmail.com>
AuthorDate: Wed Jan 16 13:52:38 2019 -0500

    AMQ-7132 - update RecoveryStatsBrokerTest back to using always journal sync 
but a smaller journal size and less test messages to speed up test
---
 .../java/org/apache/activemq/broker/RecoveryStatsBrokerTest.java     | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git 
a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/RecoveryStatsBrokerTest.java
 
b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/RecoveryStatsBrokerTest.java
index b227218..c143863 100644
--- 
a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/RecoveryStatsBrokerTest.java
+++ 
b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/RecoveryStatsBrokerTest.java
@@ -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();