Fix for: https://issues.apache.org/jira/browse/AMQ-4837 : LevelDB corrupted in AMQ cluster.

- The tracked flushed offset was not getting initialized to match the initial size of the log file. This invalid flushed offset was being used to do the initial sync /w the slave and then things went downhill.
2013-11-01 12:08:19 -04:00 · 2013-11-01 12:08:19 -04:00 · 190da29691
parent ec4c2d9464
commit 190da29691
1 changed files with 1 additions and 1 deletions
--- a/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/RecordLog.scala
+++ b/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/RecordLog.scala
@ -118,7 +118,7 @@ case class RecordLog(directory: File, logSuffix:String) {
      force
    }

-    val flushed_offset = new AtomicLong(0)
+    val flushed_offset = new AtomicLong(append_offset)

    def append_position = {
      position+append_offset