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 288ea65..49ee6c4 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
@@ -129,7 +129,7 @@ private Void handleSSEStarted(StartedEvent startedEvent) {
         isSSEConnected = true;
         DevCycleLogger.debug("SSE Connected - setting polling interval to " + pollingIntervalSSEMS);
         scheduler.close();
-        scheduler = Executors.newScheduledThreadPool(1, new DaemonThreadFactory());
+        scheduler = setupScheduler();
         scheduler.scheduleAtFixedRate(getConfigRunnable, 0, pollingIntervalSSEMS, TimeUnit.MILLISECONDS);
         return null;
     }