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 *