diff --git a/SymphonyDiscovery/src/main/java/io/github/lumijiez/JavalinConfig.java b/SymphonyDiscovery/src/main/java/io/github/lumijiez/JavalinConfig.java
index 376afdb..a3a33b2 100644
--- a/SymphonyDiscovery/src/main/java/io/github/lumijiez/JavalinConfig.java
+++ b/SymphonyDiscovery/src/main/java/io/github/lumijiez/JavalinConfig.java
@@ -1,8 +1,6 @@
 package io.github.lumijiez;
 
-import com.google.gson.Gson;
 import io.javalin.Javalin;
-import io.javalin.json.JavalinGson;
 import io.javalin.websocket.WsContext;
 
 import java.util.Map;
@@ -18,13 +16,13 @@ public class JavalinConfig {
            ws.onConnect(ctx -> {
                String id = ctx.sessionId();
                users.put(id, ctx);
-               broadcast("Discovery", "Join");
+               broadcast("Discovery-Join", "Join");
            });
 
            ws.onClose(ctx -> {
                String id = ctx.sessionId();
                users.remove(id);
-               broadcast("Discovery", "Leave");
+               broadcast("Discovery-Leave", "Leave");
            });
         });
     }
diff --git a/SymphonyDiscovery/src/main/java/io/github/lumijiez/Main.java b/SymphonyDiscovery/src/main/java/io/github/lumijiez/Main.java
index 94f7bd7..0409c29 100644
--- a/SymphonyDiscovery/src/main/java/io/github/lumijiez/Main.java
+++ b/SymphonyDiscovery/src/main/java/io/github/lumijiez/Main.java
@@ -5,9 +5,7 @@ import io.javalin.json.JavalinGson;
 
 public class Main {
     public static void main(String[] args) {
-        Javalin app = Javalin.create(config -> {
-            config.jsonMapper(new JavalinGson());
-        }).start(8083);
+        Javalin app = Javalin.create(config -> config.jsonMapper(new JavalinGson())).start(8083);
 
         JavalinConfig.setup(app);
 
diff --git a/SymphonyManager/src/main/java/io/github/lumijiez/BrokerConnector.java b/SymphonyManager/src/main/java/io/github/lumijiez/BrokerConnector.java
index a4c9870..873e23f 100644
--- a/SymphonyManager/src/main/java/io/github/lumijiez/BrokerConnector.java
+++ b/SymphonyManager/src/main/java/io/github/lumijiez/BrokerConnector.java
@@ -49,9 +49,7 @@ public class BrokerConnector {
             channel.queueDeclare(QUEUE_NAME, false, false, false, null);
             logger.info("Connected to RabbitMQ and queue declared.");
 
-            DeliverCallback deliverCallback = (consumerTag, delivery) -> {
-                channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
-            };
+            DeliverCallback deliverCallback = (consumerTag, delivery) -> channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
 
             channel.basicConsume(QUEUE_NAME, false, deliverCallback, consumerTag -> {});