logging for purge

JumpMind · Feb 24, 2008 · 5f8c880 · 5f8c880
1 parent ebf7204
commit 5f8c880
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/PurgeService.java b/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/PurgeService.java
@@ -176,6 +176,7 @@ private void purgeBatchesOlderThan(final Calendar time) {
                 .getTime() }, Integer.class);
         int eventRowCount = 0;
         int dataIdCount = 0;
+        int batchesPurged = 0;
         long ts = System.currentTimeMillis();
         for (final Integer batchId : batchIds) {
             do {
@@ -199,12 +200,12 @@ public Object doInTransaction(final TransactionStatus s) {
                 eventRowCount += dataIdCount;
 
                 if (System.currentTimeMillis() - ts > DateUtils.MILLIS_PER_MINUTE * 5) {
-                    logger.info("Purged " + batchIds.size() + " a total of batches and " + eventRowCount
+                    logger.info("Purged " + batchesPurged + " out of " + batchIds.size() + " total and " + eventRowCount
                             + " data_events.");
                     ts = System.currentTimeMillis();
                 }
             } while (dataIdCount > 0);
-
+            batchesPurged++;
         }
 
         if (batchIds.size() > 0) {