From 348370faaa643ee5c67ca005c26839cf0b98af05 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Lukas=20W=C3=B6hrl?= <lukas@woehrl.net>
Date: Mon, 28 Oct 2019 17:10:34 +0100
Subject: [PATCH] 0004127: Store count of processed files in
 sym_node_host_job_stats for StageManagementJob (#91)

---
 .../java/org/jumpmind/symmetric/job/StageManagementJob.java   | 4 +++-
 1 file changed, 3 insertions(+), 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
index 19b2dba793..156c955196 100644
--- 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);
         }
     }