add more debug

Author: chillaq

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

@@ -143,6 +143,8 @@ public void stop() {
             lock.lock();
             cleanUpResources();
             _log.debug("#2 - Stopped PushManagerImp");
+        } catch (Exception e) {
+            _log.debug("Exception in stopping push manager: " + e.getMessage());
         } finally {
             lock.unlock();
         }
@@ -173,7 +175,9 @@ private boolean startSse(String token, String channels) {
     @Override
     public void startWorkers() {
         try {
+            _log.debug("Starting featureflag worker");
             _featureFlagsWorker.start();
+            _log.debug("Starting segment worker");
             _segmentWorker.start();
         } catch (Exception e) {
             _log.debug("Exception in starting workers: " + e.getMessage());
@@ -183,7 +187,9 @@ public void startWorkers() {
     @Override
     public void stopWorkers() {
         try {
+            _log.debug("Stopping featureflag worker");
             _featureFlagsWorker.stop();
+            _log.debug("Stopping segment worker");
             _segmentWorker.stop();
         } catch (Exception e) {
             _log.debug("Exception in stopping workers: " + e.getMessage());

client/src/main/java/io/split/engine/sse/workers/Worker.java

@@ -27,6 +27,7 @@ public void start() {
             _thread = new Thread( this);
             _thread.setName(String.format("%s-worker", _workerName));
             _thread.start();
+            _log.debug(String.format("%s Worker started ...", _workerName));
         } else {
             _log.debug(String.format("%s Worker already running.", _workerName));
             return;
@@ -35,6 +36,7 @@ public void start() {
 
     public  void stop() {
         if (_running.compareAndSet(true, false)) {
+            _log.debug(String.format("%s stopping Worker", _workerName));
             _thread.interrupt();
             _log.debug(String.format("%s Worked stopped.", _workerName));
         } else {