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

fix missed sync of recovery file
2014-11-25 18:49:55 -05:00 · 2014-11-25 18:49:55 -05:00 · 4141d6a223
parent 0514fcf882
commit 4141d6a223
1 changed files with 1 additions and 1 deletions
--- a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/page/PageFile.java
+++ b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/page/PageFile.java
@ -1091,7 +1091,7 @@ public class PageFile {
            if (enableDiskSyncs) {
                // Sync to make sure recovery buffer writes land on disk..
                if (enableRecoveryFile) {
-                    writeFile.sync();
+                    recoveryFile.sync();
                }
                writeFile.sync();
            }