0004127: Store count of processed files in sym_node_host_job_stats fo…

…r OutgoingPurgeJob (#92)
JumpMind · Oct 28, 2019 · 216ed96 · 216ed96
1 parent 348370f
commit 216ed96
Showing 1 changed file with 9 additions and 9 deletions.
diff --git a/symmetric-client/src/main/java/org/jumpmind/symmetric/job/OutgoingPurgeJob.java b/symmetric-client/src/main/java/org/jumpmind/symmetric/job/OutgoingPurgeJob.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 OutgoingPurgeJob extends AbstractJob {
 
-    public OutgoingPurgeJob(ISymmetricEngine engine, ThreadPoolTaskScheduler taskScheduler) {
-        super(ClusterConstants.PURGE_OUTGOING, engine, taskScheduler);
+    public OutgoingPurgeJob(ISymmetricEngine engine, ThreadPoolTaskScheduler taskScheduler) {
+        super(ClusterConstants.PURGE_OUTGOING, engine, taskScheduler);
     }
 
     @Override
@@ -45,8 +45,8 @@ public JobDefaults getDefaults() {
     }    
 
     @Override
-    public void doJob(boolean force) throws Exception {
-        engine.getPurgeService().purgeOutgoing(force);        
+    public void doJob(boolean force) throws Exception {
+        setProcessedCount(engine.getPurgeService().purgeOutgoing(force));        
     }
 
     @Override
@@ -55,4 +55,4 @@ public String getDeprecatedStartParameter() {
     }
 
 
-}
+}