From 5800f5fcf828c19e63b0d55416860e1dff19428b Mon Sep 17 00:00:00 2001
From: Martin Thompson <mjpt777@gmail.com>
Date: Sat, 9 Jul 2016 12:25:38 +0100
Subject: [PATCH] [Java] Lag the cleaning by a term + window to allow for
 greater NAK range.

---
 .../src/main/java/io/aeron/driver/NetworkPublication.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/aeron-driver/src/main/java/io/aeron/driver/NetworkPublication.java b/aeron-driver/src/main/java/io/aeron/driver/NetworkPublication.java
index 2dd40a29df..1daf7e9d87 100644
--- a/aeron-driver/src/main/java/io/aeron/driver/NetworkPublication.java
+++ b/aeron-driver/src/main/java/io/aeron/driver/NetworkPublication.java
@@ -308,7 +308,7 @@ int updatePublishersLimit()
 
         if (publisherLimit.proposeMaxOrdered(candidatePublisherLimit))
         {
-            cleanBuffer(candidatePublisherLimit);
+            cleanBuffer(candidatePublisherLimit - termWindowLength);
 
             workCount = 1;
         }