diff --git a/ems-core/src/main/java/it/integry/ems/migration/_base/IntegryCustomerDB.java b/ems-core/src/main/java/it/integry/ems/migration/_base/IntegryCustomerDB.java index 19fbb9405b..12fe8356e2 100644 --- a/ems-core/src/main/java/it/integry/ems/migration/_base/IntegryCustomerDB.java +++ b/ems-core/src/main/java/it/integry/ems/migration/_base/IntegryCustomerDB.java @@ -191,7 +191,7 @@ public enum IntegryCustomerDB { Tosca_Vr("tosca_vr"), Tosca_Rg("tosca_rg"), Tosca_Fc("tosca_fc"), - Tosca_Cloud("tosca_cloud"), + Tosca_Cloud("tosca-primary-db"), TwoBrothers_TwoBrothers("twobrothers"), diff --git a/ems-core/src/main/java/it/integry/ems/migration/model/Migration_20250310160834.java b/ems-core/src/main/java/it/integry/ems/migration/model/Migration_20250310160835.java similarity index 91% rename from ems-core/src/main/java/it/integry/ems/migration/model/Migration_20250310160834.java rename to ems-core/src/main/java/it/integry/ems/migration/model/Migration_20250310160835.java index ffd0ea5724..66abe74a7c 100644 --- a/ems-core/src/main/java/it/integry/ems/migration/model/Migration_20250310160834.java +++ b/ems-core/src/main/java/it/integry/ems/migration/model/Migration_20250310160835.java @@ -4,7 +4,7 @@ import it.integry.ems.migration._base.BaseMigration; import it.integry.ems.migration._base.IntegryCustomerDB; import it.integry.ems.migration._base.MigrationModelInterface; -public class Migration_20250310160834 extends BaseMigration implements MigrationModelInterface { +public class Migration_20250310160835 extends BaseMigration implements MigrationModelInterface { @Override public void up() throws Exception { diff --git a/ems-core/src/main/java/it/integry/ems/sync/AsyncManager.java b/ems-core/src/main/java/it/integry/ems/sync/AsyncManager.java index d6492855b5..856130b2c6 100644 --- a/ems-core/src/main/java/it/integry/ems/sync/AsyncManager.java +++ b/ems-core/src/main/java/it/integry/ems/sync/AsyncManager.java @@ -51,10 +51,10 @@ public class AsyncManager { @PostContextConstruct public void init() { -// if ((!UtilityDebug.isDebugExecution() && !UtilityDebug.isIntegryServer())) { + if ((!UtilityDebug.isDebugExecution() && !UtilityDebug.isIntegryServer())) { looperService.add(this::internalCachePublicationsSetup, 5 * 60 * 1000, "sync-setup-cache"); looperService.add(this::consumeToBeSavedQueue, 20 * 1000, "sync-flush-data"); -// } + } } private void internalCachePublicationsSetup() {