diff --git a/src/main/java/com/devcycle/sdk/server/local/managers/EnvironmentConfigManager.java b/src/main/java/com/devcycle/sdk/server/local/managers/EnvironmentConfigManager.java index 0c5eb0a..fbea213 100644 --- a/src/main/java/com/devcycle/sdk/server/local/managers/EnvironmentConfigManager.java +++ b/src/main/java/com/devcycle/sdk/server/local/managers/EnvironmentConfigManager.java @@ -128,7 +128,7 @@ private Void handleSSEError(FaultEvent faultEvent) { private Void handleSSEStarted(StartedEvent startedEvent) { isSSEConnected = true; DevCycleLogger.debug("SSE Connected - setting polling interval to " + pollingIntervalSSEMS); - scheduler.close(); + scheduler.shutdown(); scheduler = setupScheduler(); scheduler.scheduleAtFixedRate(getConfigRunnable, 0, pollingIntervalSSEMS, TimeUnit.MILLISECONDS); return null; @@ -259,7 +259,6 @@ private ProjectConfig getConfigResponse(Call call) throws DevCycl private void stopPolling() { pollingEnabled = false; - scheduler.shutdown(); }