diff --git a/symmetric-client/src/main/java/org/jumpmind/symmetric/job/StatisticFlushJob.java b/symmetric-client/src/main/java/org/jumpmind/symmetric/job/StatisticFlushJob.java
index 1d34f64ba5..2bc66e6806 100644
--- a/symmetric-client/src/main/java/org/jumpmind/symmetric/job/StatisticFlushJob.java
+++ b/symmetric-client/src/main/java/org/jumpmind/symmetric/job/StatisticFlushJob.java
@@ -22,6 +22,7 @@
 package org.jumpmind.symmetric.job;
 
 import org.jumpmind.symmetric.ISymmetricEngine;
+import org.jumpmind.symmetric.service.ClusterConstants;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
 
 
@@ -42,7 +43,7 @@ public void doJob(boolean force) throws Exception {
     }
     
     public String getClusterLockName() {
-        return "STATISTICS";
+        return ClusterConstants.STATISTICS;
     }
     
     public boolean isClusterable() {
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/ClusterConstants.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/ClusterConstants.java
index 647128644b..a64a0c908e 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/ClusterConstants.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/ClusterConstants.java
@@ -35,6 +35,7 @@ public class ClusterConstants {
     public static final String PURGE_DATA_GAPS = "PURGE_DATA_GAPS";
     public static final String HEARTBEAT = "HEARTBEAT";
     public static final String SYNCTRIGGERS = "SYNCTRIGGERS";
-    public static final String WATCHDOG = "WATCHDOG";
+    public static final String WATCHDOG = "WATCHDOG";
+    public static final String STATISTICS = "STATISTICS";
     
 }
\ No newline at end of file
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/ClusterService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/ClusterService.java
index fa25f0445d..207365d8ab 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/ClusterService.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/ClusterService.java
@@ -29,6 +29,9 @@
 import static org.jumpmind.symmetric.service.ClusterConstants.PUSH;
 import static org.jumpmind.symmetric.service.ClusterConstants.ROUTE;
 import static org.jumpmind.symmetric.service.ClusterConstants.SYNCTRIGGERS;
+import static org.jumpmind.symmetric.service.ClusterConstants.STAGE_MANAGEMENT;
+import static org.jumpmind.symmetric.service.ClusterConstants.WATCHDOG;
+import static org.jumpmind.symmetric.service.ClusterConstants.STATISTICS;
 
 import java.util.Calendar;
 import java.util.Date;
@@ -69,6 +72,9 @@ public void init() {
         initLockTable(PURGE_STATISTICS);
         initLockTable(SYNCTRIGGERS);
         initLockTable(PURGE_DATA_GAPS);
+        initLockTable(STAGE_MANAGEMENT);
+        initLockTable(WATCHDOG);
+        initLockTable(STATISTICS);
     }
 
     public void initLockTable(final String action) {