diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/io/stage/BatchStagingManager.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/io/stage/BatchStagingManager.java index 4d9b667614..5feaaac855 100644 --- a/symmetric-core/src/main/java/org/jumpmind/symmetric/io/stage/BatchStagingManager.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/io/stage/BatchStagingManager.java @@ -36,11 +36,15 @@ protected Map getBiggestBatchIds(List batches) { @Override public long clean(long ttlInMs) { - if (!engine.getClusterService().lock(ClusterConstants.STAGE_MANAGEMENT)) { - log.debug("Could not get a lock to run stage management"); - return 0; + try { + if (!engine.getClusterService().lock(ClusterConstants.STAGE_MANAGEMENT)) { + log.debug("Could not get a lock to run stage management"); + return 0; + } + } catch (Exception e) { + // during setup or un-install, it's possible sym_lock table isn't available yet } - + try { boolean purgeBasedOnTTL = engine.getParameterService().is(ParameterConstants.STREAM_TO_FILE_PURGE_ON_TTL_ENABLED, false); if (purgeBasedOnTTL) { @@ -51,7 +55,10 @@ public long clean(long ttlInMs) { } } } finally { - engine.getClusterService().unlock(ClusterConstants.STAGE_MANAGEMENT); + try { + engine.getClusterService().unlock(ClusterConstants.STAGE_MANAGEMENT); + } catch (Exception e) { + } } } diff --git a/symmetric-server/src/main/java/org/jumpmind/symmetric/web/SymPatternLayout.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/web/SymPatternLayout.java similarity index 97% rename from symmetric-server/src/main/java/org/jumpmind/symmetric/web/SymPatternLayout.java rename to symmetric-core/src/main/java/org/jumpmind/symmetric/web/SymPatternLayout.java index 6c913786e4..43da1af674 100644 --- a/symmetric-server/src/main/java/org/jumpmind/symmetric/web/SymPatternLayout.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/web/SymPatternLayout.java @@ -23,7 +23,6 @@ import java.util.Date; import java.util.List; -import org.apache.commons.lang.time.DateUtils; import org.apache.log4j.PatternLayout; import org.jumpmind.symmetric.AbstractSymmetricEngine; import org.jumpmind.symmetric.ISymmetricEngine;