From 2d9c7555d5488f189e8d9a51caa9b6cf9755db59 Mon Sep 17 00:00:00 2001 From: Lumijiez Date: Sat, 23 Nov 2024 00:15:40 +0200 Subject: [PATCH] Comment unneeded line --- .../src/main/java/io/github/lumijiez/BrokerConnector.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/SymphonyManager/src/main/java/io/github/lumijiez/BrokerConnector.java b/SymphonyManager/src/main/java/io/github/lumijiez/BrokerConnector.java index 0d18341..ecd6f7c 100644 --- a/SymphonyManager/src/main/java/io/github/lumijiez/BrokerConnector.java +++ b/SymphonyManager/src/main/java/io/github/lumijiez/BrokerConnector.java @@ -5,7 +5,6 @@ import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; import com.rabbitmq.client.DeliverCallback; -import java.nio.charset.StandardCharsets; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; @@ -41,8 +40,7 @@ public class BrokerConnector { System.out.println("Waiting for messages. To exit press CTRL+C"); DeliverCallback deliverCallback = (consumerTag, delivery) -> { - String message = new String(delivery.getBody(), StandardCharsets.UTF_8); -// System.out.println("Received: " + message); + // String message = new String(delivery.getBody(), StandardCharsets.UTF_8); channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false); };