Adds some more logging (#12)

teragrep · Nov 20, 2023 · 54b7ec1 · 54b7ec1
1 parent 590e714
commit 54b7ec1
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/main/java/com/teragrep/jla_05/RelpAppender.java b/src/main/java/com/teragrep/jla_05/RelpAppender.java
@@ -153,6 +153,7 @@ private void disconnect() throws IOException, TimeoutException {
         }
         try {
             this.relpConnection.disconnect();
+            System.out.printf("Disconnected from <[%s]>:<[%s]>%n", relpAddress, relpPort);
         } catch (IllegalStateException | IOException | java.util.concurrent.TimeoutException e) {
             System.out.printf("RelpAppender.disconnect exception: <%s>%n", e.getMessage());
         }
@@ -167,6 +168,7 @@ private void connect() {
                 this.relpConnection.setReadTimeout(this.getReadTimeout());
                 this.relpConnection.setWriteTimeout(this.getWriteTimeout());
                 this.connected = this.relpConnection.connect(this.getRelpAddress(), this.getRelpPort());
+                System.out.printf("Connected to <[%s]>:<[%s]>%n", relpAddress, relpPort);
             } catch (Exception e) {
                 System.out.printf("RelpAppender.connect exception: <%s>%n", e.getMessage());
             }
@@ -241,6 +243,7 @@ protected void append(final LoggingEvent event) {
                 batch.retryAllFailed();
                 try {
                     reconnect();
+                    System.out.printf("Reconnected to <[%s]>:<[%s]>%n", relpAddress, relpPort);
                 } catch (IOException | TimeoutException e) {
                     System.out.printf("RelpAppender.flush.reconnect exception: <%s>%n", e.getMessage());
                 }