0004127: Store count of processed files in sym_node_host_job_stats fo…

…r IncomingPurgeJob (#93)
JumpMind · Oct 28, 2019 · 7501332 · 7501332
1 parent 72ebb77
commit 7501332
Showing 1 changed file with 9 additions and 9 deletions.
diff --git a/symmetric-client/src/main/java/org/jumpmind/symmetric/job/IncomingPurgeJob.java b/symmetric-client/src/main/java/org/jumpmind/symmetric/job/IncomingPurgeJob.java
@@ -26,15 +26,15 @@
 import org.jumpmind.symmetric.ISymmetricEngine;
 import org.jumpmind.symmetric.common.ParameterConstants;
 import org.jumpmind.symmetric.service.ClusterConstants;
-import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
 
-/*
- * Background job that is responsible for purging already synchronized data
- */
+/*
+ * Background job that is responsible for purging already synchronized data
+ */
 public class IncomingPurgeJob extends AbstractJob {
 
-    public IncomingPurgeJob(ISymmetricEngine engine, ThreadPoolTaskScheduler taskScheduler) {
-        super(ClusterConstants.PURGE_INCOMING, engine, taskScheduler);
+    public IncomingPurgeJob(ISymmetricEngine engine, ThreadPoolTaskScheduler taskScheduler) {
+        super(ClusterConstants.PURGE_INCOMING, engine, taskScheduler);
     }
 
     @Override
@@ -45,13 +45,13 @@ public JobDefaults getDefaults() {
     }    
 
     @Override
-    public void doJob(boolean force) throws Exception {
-        engine.getPurgeService().purgeIncoming(force);  
+    public void doJob(boolean force) throws Exception {
+        setProcessedCount(engine.getPurgeService().purgeIncoming(force)); 
     }
 
     @Override
     public String getDeprecatedStartParameter() {
         return ParameterConstants.START_PURGE_JOB_38;
     }
 
-}
+}