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
+}