[Java] Correct comparison order for appended message test against clu…

…ster commit position.
real-logic · Jul 18, 2019 · 50aeaf0 · 50aeaf0
1 parent cc5dfed
commit 50aeaf0
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/aeron-cluster/src/main/java/io/aeron/cluster/ConsensusModuleAgent.java b/aeron-cluster/src/main/java/io/aeron/cluster/ConsensusModuleAgent.java
@@ -2657,10 +2657,9 @@ private boolean leaderServiceSessionMessageSweeper(
         final int timestampOffset = headerOffset + SessionMessageHeaderDecoder.timestampEncodingOffset();
         final long appendPosition = buffer.getLong(timestampOffset, SessionMessageHeaderDecoder.BYTE_ORDER);
 
-        if (appendPosition >= commitPosition.getWeak())
+        if (commitPosition.getWeak() >= appendPosition)
         {
             --uncommittedServiceMessages;
-
             return true;
         }