Repository: activemq Updated Branches: refs/heads/trunk 0514fcf88 -> 4141d6a22
https://issues.apache.org/jira/browse/AMQ-5444 fix missed sync of recovery file Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/4141d6a2 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/4141d6a2 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/4141d6a2 Branch: refs/heads/trunk Commit: 4141d6a2231f459cbed3c9b5fce7b54f1cdf3860 Parents: 0514fcf Author: Timothy Bish <[email protected]> Authored: Tue Nov 25 18:49:55 2014 -0500 Committer: Timothy Bish <[email protected]> Committed: Tue Nov 25 18:49:55 2014 -0500 ---------------------------------------------------------------------- .../java/org/apache/activemq/store/kahadb/disk/page/PageFile.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/4141d6a2/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/disk/page/PageFile.java ---------------------------------------------------------------------- diff --git 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 index 17d6a54..dbd7dc8 100644 --- 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(); }
