0004079: Refresh lock for purge service

JumpMind · Aug 27, 2019 · ad4f0b6 · ad4f0b6
1 parent 3764762
commit ad4f0b6
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PurgeService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PurgeService.java
@@ -440,11 +440,11 @@ private int purgeByMinMax(long[] minMax, long minGapStartId, MinMaxDeleteSql ide
             log.debug("Deleted {} rows", count);
             totalCount += count;
 
-            if (totalCount > 0
-                    && (System.currentTimeMillis() - ts > DateUtils.MILLIS_PER_MINUTE * 5)) {
+            if (System.currentTimeMillis() - ts > DateUtils.MILLIS_PER_MINUTE * 5) {
                 log.info("Purged {} of {} rows so far using {} statements", new Object[] {
                         totalCount, identifier.toString().toLowerCase(), totalDeleteStmts });
                 ts = System.currentTimeMillis();
+                clusterService.refreshLock(ClusterConstants.PURGE_OUTGOING);
             }
             minId = maxId + 1;
         }