From 339904ac4cc88521e21b07e2f33b55fe6621d70c Mon Sep 17 00:00:00 2001
From: Lumijiez <danthevip@gmail.com>
Date: Sun, 24 Nov 2024 01:51:47 +0200
Subject: [PATCH] Removed OK's from logging, not needed

---
 .../src/main/java/io/github/lumijiez/Main.java        | 11 +++++------
 .../src/main/java/io/github/lumijiez/Main.java        |  2 +-
 .../main/java/io/github/lumijiez/BrokerConnector.java |  2 +-
 .../main/java/io/github/lumijiez/BrokerConnector.java |  6 +++---
 4 files changed, 10 insertions(+), 11 deletions(-)

diff --git a/SymphonyDatabaseNode/src/main/java/io/github/lumijiez/Main.java b/SymphonyDatabaseNode/src/main/java/io/github/lumijiez/Main.java
index bbb4455..e114218 100644
--- a/SymphonyDatabaseNode/src/main/java/io/github/lumijiez/Main.java
+++ b/SymphonyDatabaseNode/src/main/java/io/github/lumijiez/Main.java
@@ -8,7 +8,6 @@ import org.apache.logging.log4j.LogManager;
 import java.net.URI;
 import java.net.http.HttpClient;
 import java.net.http.WebSocket;
-import java.nio.ByteBuffer;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.CompletionStage;
 import java.util.concurrent.CountDownLatch;
@@ -19,10 +18,10 @@ public class Main {
 
     public static void main(String[] args) {
         try {
-            logger.info("Node up. - OK");
+            logger.info("Node started");
             EntityManager em = Data.getEntityManager();
 
-            logger.info("Connected to database: << symphony >> - OK");
+            logger.info("Connected to database: << symphony >>");
             em.close();
 
             try (HttpClient client = HttpClient.newHttpClient()) {
@@ -33,7 +32,7 @@ public class Main {
                             public CompletionStage<?> onText(WebSocket webSocket, CharSequence data, boolean last) {
                                 try {
                                     int nodeCount = Integer.parseInt(data.toString());
-                                    logger.info("Acknowledged nodes: {} - OK", nodeCount);
+                                    logger.info("Acknowledged nodes: {}", nodeCount);
                                 } catch (NumberFormatException e) {
                                     logger.error("Received invalid node count: {}", data);
                                 }
@@ -42,7 +41,7 @@ public class Main {
 
                             @Override
                             public void onOpen(WebSocket webSocket) {
-                                logger.info("Successfully registered to Discovery - OK");
+                                logger.info("Successfully registered to Discovery");
                                 waitForConnection.countDown();
                                 WebSocket.Listener.super.onOpen(webSocket);
                             }
@@ -66,7 +65,7 @@ public class Main {
                     waitForConnection.await();
                     Thread.currentThread().join();
                 } finally {
-                    ws.sendClose(WebSocket.NORMAL_CLOSURE, "Node shutting down. - OK").join();
+                    ws.sendClose(WebSocket.NORMAL_CLOSURE, "Node shutting down").join();
                 }
             }
 
diff --git a/SymphonyDiscovery/src/main/java/io/github/lumijiez/Main.java b/SymphonyDiscovery/src/main/java/io/github/lumijiez/Main.java
index 47014ac..ed7f688 100644
--- a/SymphonyDiscovery/src/main/java/io/github/lumijiez/Main.java
+++ b/SymphonyDiscovery/src/main/java/io/github/lumijiez/Main.java
@@ -20,6 +20,6 @@ public class Main {
 
         JavalinConfig.setup(app);
 
-        logger.info("Discovery service up and running. - OK");
+        logger.info("Discovery service up and running");
     }
 }
\ No newline at end of file
diff --git a/SymphonyManager/src/main/java/io/github/lumijiez/BrokerConnector.java b/SymphonyManager/src/main/java/io/github/lumijiez/BrokerConnector.java
index 76ea885..89555fb 100644
--- a/SymphonyManager/src/main/java/io/github/lumijiez/BrokerConnector.java
+++ b/SymphonyManager/src/main/java/io/github/lumijiez/BrokerConnector.java
@@ -47,7 +47,7 @@ public class BrokerConnector {
              Channel channel = connection.createChannel()) {
 
             channel.queueDeclare(QUEUE_NAME, false, false, false, null);
-            logger.info("Connected to RabbitMQ and queue declared. - OK");
+            logger.info("Connected to RabbitMQ and queue declared");
 
             DeliverCallback deliverCallback = (consumerTag, delivery) -> channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
 
diff --git a/SymphonyProducer/src/main/java/io/github/lumijiez/BrokerConnector.java b/SymphonyProducer/src/main/java/io/github/lumijiez/BrokerConnector.java
index 516e3da..dcd40db 100644
--- a/SymphonyProducer/src/main/java/io/github/lumijiez/BrokerConnector.java
+++ b/SymphonyProducer/src/main/java/io/github/lumijiez/BrokerConnector.java
@@ -27,12 +27,12 @@ public class BrokerConnector {
         CountDownLatch latch = new CountDownLatch(1);
 
         Runtime.getRuntime().addShutdownHook(new Thread(() -> {
-            logger.info("Shutdown signal received. - OK");
+            logger.info("Shutdown signal received");
             latch.countDown();
         }));
 
         boolean success = connectToRabbitMQ(latch);
-        logger.info("Success: {} - OK", success);
+        logger.info("Success: {}", success);
     }
 
     private static boolean connectToRabbitMQ(CountDownLatch latch) {
@@ -46,7 +46,7 @@ public class BrokerConnector {
              ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor()) {
 
             channel.queueDeclare(QUEUE_NAME, false, false, false, null);
-            logger.info("Connected to RabbitMQ and queue declared. - OK");
+            logger.info("Connected to RabbitMQ and queue declared");
 
             scheduler.scheduleAtFixedRate(() -> {
                 try {