restore some logging

Author: mredolatti

client/src/main/java/io/split/engine/sse/AuthApiClientImp.java

@@ -46,14 +46,14 @@ public AuthenticationResponse Authenticate() {
                 return getSuccessResponse(jsonContent);
             }
 
-            _log.debug(String.format("Problem to connect to : %s. Response status: %s", _target, statusCode));
+            _log.error(String.format("Problem to connect to : %s. Response status: %s", _target, statusCode));
             if (statusCode >= HttpStatus.SC_BAD_REQUEST && statusCode < HttpStatus.SC_INTERNAL_SERVER_ERROR) {
                 return new AuthenticationResponse(false,false);
             }
 
             return new AuthenticationResponse(false,true);
         } catch (Exception ex) {
-            _log.debug(ex.getMessage());
+            _log.error(ex.getMessage());
             return new AuthenticationResponse(false,true);
         }
     }

client/src/main/java/io/split/engine/sse/EventSourceClientImp.java

@@ -65,15 +65,15 @@ public boolean start(String channelList, String token) {
         try {
             return _sseClient.open(buildUri(channelList, token));
         } catch (URISyntaxException e) {
-            _log.debug("Error building Streaming URI: " + e.getMessage());
+            _log.error("Error building Streaming URI: " + e.getMessage());
             return false;
         }
     }
 
     @Override
     public void stop() {
         if (!_sseClient.isOpen()) {
-            _log.debug("Event Source Client is closed.");
+            _log.info("Event Source Client is closed.");
             return;
         }
         _sseClient.close();

client/src/main/java/io/split/engine/sse/client/SSEClient.java

@@ -65,7 +65,7 @@ public SSEClient(Function<RawEvent, Void> eventCallback,
 
     public synchronized boolean open(URI uri) {
         if (isOpen()) {
-            _log.debug("SSEClient already open.");
+            _log.info("SSEClient already open.");
             return false;
         }
 
@@ -79,7 +79,7 @@ public synchronized boolean open(URI uri) {
             }
         } catch (InterruptedException e) {
             Thread.currentThread().interrupt();
-            _log.debug(e.getMessage());
+            _log.info(e.getMessage());
             return false;
         }
         return isOpen();
@@ -96,7 +96,7 @@ public synchronized void close() {
                     _ongoingRequest.get().abort();
                     _ongoingResponse.get().close();
                 } catch (IOException e) {
-                    _log.debug(String.format("Error closing SSEClient: %s", e.getMessage()));
+                    _log.info(String.format("Error closing SSEClient: %s", e.getMessage()));
                 }
             }
         }
@@ -127,7 +127,7 @@ private void connectAndLoop(URI uri, CountDownLatch signal) {
                     _statusCallback.apply(StatusMessage.RETRYABLE_ERROR);
                     return;
                 } catch (IOException exc) { // Other type of connection error
-                    _log.debug(exc.getMessage());
+                    _log.info(String.format("SSE connection ended abruptly: %s. Retying", exc.getMessage()));
                     _statusCallback.apply(StatusMessage.RETRYABLE_ERROR);
                     return;
                 }
@@ -159,7 +159,7 @@ private boolean establishConnection(URI uri, CountDownLatch signal) {
             _state.set(ConnectionState.OPEN);
             _statusCallback.apply(StatusMessage.CONNECTED);
         } catch (IOException exc) {
-            _log.debug(String.format("Error establishConnection: %s", exc));
+            _log.error(String.format("Error establishConnection: %s", exc));
             return false;
         } finally {
             signal.countDown();