From 75fda65970158df4bc336971a50c82222e31a09a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Lukas=20W=C3=B6hrl?= Date: Fri, 4 May 2018 14:21:17 +0200 Subject: [PATCH] clear caches on a restart of the server --- .../symmetric/AbstractSymmetricEngine.java | 15 +++++++++++++++ 1 file changed, 15 insertions(+) diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/AbstractSymmetricEngine.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/AbstractSymmetricEngine.java index f08518d82f..0fb8f3a5b0 100644 --- a/symmetric-core/src/main/java/org/jumpmind/symmetric/AbstractSymmetricEngine.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/AbstractSymmetricEngine.java @@ -634,6 +634,8 @@ public synchronized boolean start() { return start(true); } + private boolean isFirstStart = true; + public synchronized boolean start(boolean startJobs) { isInitialized = false; if (!starting && !started) { @@ -703,6 +705,12 @@ public synchronized boolean start(boolean startJobs) { if (parameterService.isRegistrationServer()) { this.updateService.init(); } + + if(isFirstStart){ + isFirstStart = false; + }else{ + this.clearCaches(); + } lastRestartTime = new Date(); statisticManager.incrementRestart(); @@ -990,6 +998,7 @@ public void openRegistration(String nodeGroupId, String externalId) { } public void clearCaches() { + getExtensionService().refresh(); getTriggerRouterService().clearCache(); getParameterService().rereadParameters(); getTransformService().clearCache(); @@ -997,7 +1006,13 @@ public void clearCaches() { getConfigurationService().initDefaultChannels(); getConfigurationService().clearCache(); getNodeService().flushNodeAuthorizedCache(); + getNodeService().flushNodeCache(); + getNodeService().flushNodeGroupCache(); getJobManager().startJobsAfterConfigChange(); + getLoadFilterService().clearCache(); + getMonitorService().flushMonitorCache(); + getMonitorService().flushNotificationCache(); + getFileSyncService().clearCache(); } public void reOpenRegistration(String nodeId) {