improvements

Author: sanzmauro

client/src/main/java/io/split/engine/common/SyncManager.java

@@ -1,8 +1,5 @@
 package io.split.engine.common;
 
-import io.split.engine.sse.listeners.FeedbackLoopListener;
-import io.split.engine.sse.listeners.NotificationKeeperListener;
-
 public interface SyncManager {
     void start();
     void shutdown();

client/src/main/java/io/split/engine/segments/SegmentSynchronizationTaskImp.java

@@ -8,7 +8,6 @@
 import org.slf4j.LoggerFactory;
 
 import java.io.Closeable;
-import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 import java.util.concurrent.*;
@@ -57,11 +56,12 @@ public SegmentSynchronizationTaskImp(SegmentChangeFetcher segmentChangeFetcher,
     public void run() {
         try {
             _gates.waitUntilInternalReady();
-            _running.set(true);
         } catch (InterruptedException ex) {
             _log.debug(ex.getMessage());
         }
 
+        _running.set(true);
+        _log.debug("Starting PeriodicFetching Segments ...");
         this.fetchAll(false);
     }
 
@@ -111,7 +111,6 @@ public void startPeriodicFetching() {
             return;
         }
 
-        _log.debug("Starting PeriodicFetching Segments ...");
         _scheduledFuture = _scheduledExecutorService.scheduleWithFixedDelay(this, 0L, _refreshEveryNSeconds.get(), TimeUnit.SECONDS);
     }