Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
0000845: The STAGE_MANGEMENT and WATCHDOG jobs are not initialized (t…
…hey won't work in a clustered environment)
  • Loading branch information
chenson42 committed Oct 3, 2012
1 parent 332dfd2 commit 580dd3d
Show file tree
Hide file tree
Showing 3 changed files with 10 additions and 2 deletions.
Expand Up @@ -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;


Expand All @@ -42,7 +43,7 @@ public void doJob(boolean force) throws Exception {
}

public String getClusterLockName() {
return "STATISTICS";
return ClusterConstants.STATISTICS;
}

public boolean isClusterable() {
Expand Down
Expand Up @@ -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";

}
Expand Down
Expand Up @@ -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;
Expand Down Expand Up @@ -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) {
Expand Down

0 comments on commit 580dd3d

Please sign in to comment.