Merge pull request #215 from splitio/telemetry-stats

Adding Stop

Author: ldecheverz-split

client/src/main/java/io/split/telemetry/synchronizer/TelemetrySyncTask.java

@@ -34,4 +34,13 @@ protected void startScheduledTask() throws Exception {
             }
         },0l,  _telemetryRefreshRate, TimeUnit.SECONDS);
     }
+
+    protected void stopScheduledTask() {
+        try {
+            _telemetrySynchronizer.synchronizeStats();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        _telemetrySyncScheduledExecutorService.shutdown();
+    }
 }

client/src/test/java/io/split/telemetry/synchronizer/TelemetrySyncTaskTest.java

@@ -14,4 +14,17 @@ public void testSynchronizationTask() throws Exception {
         Mockito.verify(telemetrySynchronizer, Mockito.times(3)).synchronizeStats();
     }
 
+    @Test
+    public void testStopSynchronizationTask() throws Exception {
+        TelemetrySynchronizer telemetrySynchronizer = Mockito.mock(SynchronizerMemory.class);
+        TelemetrySyncTask telemetrySyncTask = new TelemetrySyncTask(1, telemetrySynchronizer);
+        telemetrySyncTask.startScheduledTask();
+        Thread.sleep(3000);
+        Mockito.verify(telemetrySynchronizer, Mockito.times(3)).synchronizeStats();
+        telemetrySyncTask.stopScheduledTask();
+        Thread.sleep(2000);
+        Mockito.verify(telemetrySynchronizer, Mockito.times(4)).synchronizeStats();
+
+    }
+
 }