0004127: Store count of processed files in sym_node_host_job_stats fo…

…r StageManagementJob (#91)
JumpMind · Oct 28, 2019 · 348370f · 348370f
1 parent b109d67
commit 348370f
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/symmetric-client/src/main/java/org/jumpmind/symmetric/job/StageManagementJob.java b/symmetric-client/src/main/java/org/jumpmind/symmetric/job/StageManagementJob.java
@@ -45,8 +45,10 @@ public JobDefaults getDefaults() {
     public void doJob(boolean force) throws Exception {
         IStagingManager stagingManager = engine.getStagingManager();
         if (stagingManager != null) {
-            stagingManager.clean(engine.getParameterService()
+            long processed = stagingManager.clean(engine.getParameterService()
                     .getLong(ParameterConstants.STREAM_TO_FILE_TIME_TO_LIVE_MS));
+
+            setProcessedCount(processed);
         }
     }