fix for ChronicleReader infinite loop

OpenHFT · Dec 1, 2017 · b7e4cbd · b7e4cbd
1 parent 2d603ba
commit b7e4cbd
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/net/openhft/chronicle/queue/reader/ChronicleReader.java b/src/main/java/net/openhft/chronicle/queue/reader/ChronicleReader.java
@@ -150,7 +150,8 @@ ChronicleReader withDocumentPollMethod(final Function<ExcerptTailer, DocumentCon
     }
 
     private boolean queueHasBeenModifiedSinceLastCheck(final long lastObservedTailIndex) {
-        return getCurrentTailIndex() != lastObservedTailIndex;
+        long currentTailIndex = getCurrentTailIndex();
+        return currentTailIndex > lastObservedTailIndex;
     }
 
     private void moveToSpecifiedPosition(final ChronicleQueue ic, final ExcerptTailer tailer, final boolean isFirstIteration) {