use topic exchanges

Mineaurion · Feb 25, 2024 · 439004d · 439004d
1 parent 9747cea
commit 439004d
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/common/src/main/java/com/mineaurion/aurionchat/common/ChatService.java b/common/src/main/java/com/mineaurion/aurionchat/common/ChatService.java
@@ -69,10 +69,10 @@ public void reCreateConnection() throws IOException {
     }
 
     private void join() throws IOException{
-        channel.exchangeDeclare(EXCHANGE_NAME, "fanout");
+        channel.exchangeDeclare(EXCHANGE_NAME, "topic");
 
         String queue = channel.queueDeclare().getQueue();
-        channel.queueBind(queue, EXCHANGE_NAME, "");
+        channel.queueBind(queue, EXCHANGE_NAME, "#");
 
         channel.basicConsume(queue, true, consumer(), consumerTag -> {});
     }
@@ -106,7 +106,7 @@ public void send(AurionPacket.Builder builder) throws IOException {
         AurionPacket packet = builder.source(config.getString("server-name", "ingame")).build();
 
         // send
-        channel.basicPublish(EXCHANGE_NAME, "", null, packet.toString().getBytes());
+        channel.basicPublish(EXCHANGE_NAME, packet.getChannel(), null, packet.toString().getBytes());
     }
     public void close(){
         try {