https://issues.apache.org/jira/browse/AMQ-6377

Adding new setters to KahaDBPersistenceAdapter
fenglove · Jul 27, 2016 · 498e218 · 498e218
1 parent 7ac89ad
commit 498e218
Showing 1 changed file with 30 additions and 1 deletion.
diff --git a/...kahadb-store/src/main/java/org/apache/activemq/store/kahadb/KahaDBPersistenceAdapter.java b/...kahadb-store/src/main/java/org/apache/activemq/store/kahadb/KahaDBPersistenceAdapter.java
@@ -433,7 +433,7 @@ public void setIndexDirectory(File indexDirectory) {
 
     /**
      * Get the enableJournalDiskSyncs
-     *
+     * @deprecated use {@link #setEnableJournalDiskSyncs} instead
      * @return the enableJournalDiskSyncs
      */
     public boolean isEnableJournalDiskSyncs() {
@@ -443,13 +443,42 @@ public boolean isEnableJournalDiskSyncs() {
     /**
      * Set the enableJournalDiskSyncs
      *
+     * @deprecated use {@link #setEnableJournalDiskSyncs} instead
      * @param enableJournalDiskSyncs
      *            the enableJournalDiskSyncs to set
      */
     public void setEnableJournalDiskSyncs(boolean enableJournalDiskSyncs) {
         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
      *