From 498e2184be8ade23e3b1c65c5f13076ae582b493 Mon Sep 17 00:00:00 2001
From: "Christopher L. Shannon (cshannon)" <christopher.l.shannon@gmail.com>
Date: Wed, 27 Jul 2016 17:32:21 -0400
Subject: [PATCH] https://issues.apache.org/jira/browse/AMQ-6377

Adding new setters to KahaDBPersistenceAdapter
---
 .../kahadb/KahaDBPersistenceAdapter.java      | 31 ++++++++++++++++++-
 1 file changed, 30 insertions(+), 1 deletion(-)

diff --git a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/KahaDBPersistenceAdapter.java b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/KahaDBPersistenceAdapter.java
index e5d268c571..428646dc8d 100644
--- a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/KahaDBPersistenceAdapter.java
+++ b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/KahaDBPersistenceAdapter.java
@@ -433,7 +433,7 @@ public class KahaDBPersistenceAdapter extends LockableServiceSupport implements
 
     /**
      * Get the enableJournalDiskSyncs
-     *
+     * @deprecated use {@link #setEnableJournalDiskSyncs} instead
      * @return the enableJournalDiskSyncs
      */
     public boolean isEnableJournalDiskSyncs() {
@@ -443,6 +443,7 @@ public class KahaDBPersistenceAdapter extends LockableServiceSupport implements
     /**
      * Set the enableJournalDiskSyncs
      *
+     * @deprecated use {@link #setEnableJournalDiskSyncs} instead
      * @param enableJournalDiskSyncs
      *            the enableJournalDiskSyncs to set
      */
@@ -450,6 +451,34 @@ public class KahaDBPersistenceAdapter extends LockableServiceSupport implements
         this.letter.setEnableJournalDiskSyncs(enableJournalDiskSyncs);
     }
 
+    /**
+     * @return
+     */
+    public String getJournalDiskSyncStrategy() {
+        return letter.getJournalDiskSyncStrategy();
+    }
+
+    /**
+     * @param journalDiskSyncStrategy
+     */
+    public void setJournalDiskSyncStrategy(String journalDiskSyncStrategy) {
+        letter.setJournalDiskSyncStrategy(journalDiskSyncStrategy);
+    }
+
+    /**
+     * @return
+     */
+    public long getJournalDiskSyncInterval() {
+        return letter.getJournalDiskSyncInterval();
+    }
+
+    /**
+     * @param journalDiskSyncInterval
+     */
+    public void setJournalDiskSyncInterval(long journalDiskSyncInterval) {
+        letter.setJournalDiskSyncInterval(journalDiskSyncInterval);
+    }
+
     /**
      * Get the indexCacheSize
      *