From 7501332b1ddd00f2f7aa7918fda48444d514b7e2 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Lukas=20W=C3=B6hrl?= Date: Mon, 28 Oct 2019 17:08:27 +0100 Subject: [PATCH] 0004127: Store count of processed files in sym_node_host_job_stats for IncomingPurgeJob (#93) --- .../symmetric/job/IncomingPurgeJob.java | 18 +++++++++--------- 1 file changed, 9 insertions(+), 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 index ef5649d3ca..05ba823058 100644 --- 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,8 +45,8 @@ 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 @@ -54,4 +54,4 @@ public String getDeprecatedStartParameter() { return ParameterConstants.START_PURGE_JOB_38; } -} \ No newline at end of file +}