byte/symphony
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix stupid code

Browse Source
This commit is contained in:
Lumijiez
2024-11-24 00:31:54 +02:00
parent 6464ea2986
commit 32272c5295
3 changed files with 4 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
SymphonyDiscovery/src/main/java/io/github/lumijiez/JavalinConfig.java
View File

@@ -1,8 +1,6 @@
package io.github.lumijiez; package io.github.lumijiez;
import com.google.gson.Gson;
import io.javalin.Javalin; import io.javalin.Javalin;
import io.javalin.json.JavalinGson;
import io.javalin.websocket.WsContext; import io.javalin.websocket.WsContext;
import java.util.Map; import java.util.Map;
@@ -18,13 +16,13 @@ public class JavalinConfig {
ws.onConnect(ctx -> { ws.onConnect(ctx -> {
String id = ctx.sessionId(); String id = ctx.sessionId();
users.put(id, ctx); users.put(id, ctx);
broadcast("Discovery", "Join"); broadcast("Discovery-Join", "Join");
}); });
ws.onClose(ctx -> { ws.onClose(ctx -> {
String id = ctx.sessionId(); String id = ctx.sessionId();
users.remove(id); users.remove(id);
broadcast("Discovery", "Leave"); broadcast("Discovery-Leave", "Leave");
}); });
}); });
} }

4
SymphonyDiscovery/src/main/java/io/github/lumijiez/Main.java
View File

@@ -5,9 +5,7 @@ import io.javalin.json.JavalinGson;
public class Main { public class Main {
public static void main(String[] args) { public static void main(String[] args) {
Javalin app = Javalin.create(config -> { Javalin app = Javalin.create(config -> config.jsonMapper(new JavalinGson())).start(8083);
config.jsonMapper(new JavalinGson());
}).start(8083);
JavalinConfig.setup(app); JavalinConfig.setup(app);

4
SymphonyManager/src/main/java/io/github/lumijiez/BrokerConnector.java
View File

@@ -49,9 +49,7 @@ public class BrokerConnector {
channel.queueDeclare(QUEUE_NAME, false, false, false, null); channel.queueDeclare(QUEUE_NAME, false, false, false, null);
logger.info("Connected to RabbitMQ and queue declared."); logger.info("Connected to RabbitMQ and queue declared.");
DeliverCallback deliverCallback = (consumerTag, delivery) -> { DeliverCallback deliverCallback = (consumerTag, delivery) -> channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
};
channel.basicConsume(QUEUE_NAME, false, deliverCallback, consumerTag -> {}); channel.basicConsume(QUEUE_NAME, false, deliverCallback, consumerTag -> {});