From ea237b5c29b3b000fcd9e606939d920a557154c4 Mon Sep 17 00:00:00 2001 From: Luca Frosini Date: Thu, 17 Nov 2022 17:28:39 +0100 Subject: [PATCH] Fixing startup --- .../executor/SmartExecutorInitializator.java | 17 +++++++++++++++-- 1 file changed, 15 insertions(+), 2 deletions(-) diff --git a/src/main/java/org/gcube/vremanagement/executor/SmartExecutorInitializator.java b/src/main/java/org/gcube/vremanagement/executor/SmartExecutorInitializator.java index 2816137..4b246bc 100644 --- a/src/main/java/org/gcube/vremanagement/executor/SmartExecutorInitializator.java +++ b/src/main/java/org/gcube/vremanagement/executor/SmartExecutorInitializator.java @@ -1,5 +1,6 @@ package org.gcube.vremanagement.executor; +import java.io.IOException; import java.util.ArrayList; import java.util.List; import java.util.Map; @@ -19,6 +20,7 @@ import org.gcube.vremanagement.executor.persistence.SmartExecutorPersistenceConn import org.gcube.vremanagement.executor.persistence.SmartExecutorPersistenceFactory; import org.gcube.vremanagement.executor.plugin.Plugin; import org.gcube.vremanagement.executor.pluginmanager.PluginManager; +import org.gcube.vremanagement.executor.rest.RequestFilter; import org.gcube.vremanagement.executor.scheduledtask.ScheduledTask; import org.gcube.vremanagement.executor.scheduler.SmartExecutorScheduler; import org.gcube.vremanagement.executor.scheduler.SmartExecutorSchedulerFactory; @@ -47,6 +49,13 @@ public class SmartExecutorInitializator implements ApplicationManager { */ @Override public void onInit() { + RequestFilter requestFilter = new RequestFilter(); + try { + requestFilter.filter(null); + } catch (IOException e) { + throw new RuntimeException(e); + } + String context = ContextUtility.getCurrentContext(); logger.trace( @@ -174,7 +183,6 @@ public class SmartExecutorInitializator implements ApplicationManager { + "Smart Executor Started Successfully on context {}\n" + "-------------------------------------------------------", context); - } /** @@ -185,7 +193,12 @@ public class SmartExecutorInitializator implements ApplicationManager { */ @Override public void onShutdown(){ - + RequestFilter requestFilter = new RequestFilter(); + try { + requestFilter.filter(null); + } catch (IOException e) { + throw new RuntimeException(e); + } logger.trace( "\n-------------------------------------------------------\n"