[activemq] branch master updated: AMQ-7132 - user periodic fsync in RecoveryStatsBrokerTest to improve performance

[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 ae35756  AMQ-7132 - user periodic fsync in RecoveryStatsBrokerTest to 
improve performance
ae35756 is described below

commit ae357564b4e045fa4b05f925e4d8c1be5a8fe91c
Author: Christopher L. Shannon (cshannon) <christopher.l.shan...@gmail.com>
AuthorDate: Wed Jan 16 06:28:47 2019 -0500

    AMQ-7132 - user periodic fsync in RecoveryStatsBrokerTest to improve 
performance
---
 .../test/java/org/apache/activemq/broker/RecoveryStatsBrokerTest.java | 4 ++++
 1 file changed, 4 insertions(+)

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 3692574..b227218 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
@@ -30,6 +30,7 @@ import org.apache.activemq.command.ProducerInfo;
 import org.apache.activemq.command.SessionInfo;
 import org.apache.activemq.store.MessageStoreStatistics;
 import org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
+import 
org.apache.activemq.store.kahadb.disk.journal.Journal.JournalDiskSyncStrategy;
 import org.apache.activemq.util.IOHelper;
 import org.junit.After;
 import org.junit.Before;
@@ -61,6 +62,7 @@ public class RecoveryStatsBrokerTest extends 
BrokerRestartTestSupport {
     protected void configureBroker(BrokerService broker) throws Exception {
         KahaDBPersistenceAdapter persistenceAdapter = new 
KahaDBPersistenceAdapter();
         persistenceAdapter.setJournalMaxFileLength(1024*1024);
+        
persistenceAdapter.setJournalDiskSyncStrategy(JournalDiskSyncStrategy.PERIODIC.name());
         //persistenceAdapter.setConcurrentStoreAndDispatchQueues(false);
         persistenceAdapter.setDirectory(broker.getBrokerDataDirectory());
         broker.setPersistenceAdapter(persistenceAdapter);
@@ -116,11 +118,13 @@ public class RecoveryStatsBrokerTest extends 
BrokerRestartTestSupport {
         this.restartType = restartType;
     }
 
+    @Override
     @Before
     public void setUp() throws Exception {
         super.setUp();
     }
 
+    @Override
     @After
     public void tearDown() throws Exception {
         super.tearDown();