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

Comment unneeded line

Browse Source
This commit is contained in:
Lumijiez
2024-11-23 00:15:40 +02:00
parent 7654a92e28
commit 2d9c7555d5
1 changed files with 1 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -5,7 +5,6 @@ import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory; import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.DeliverCallback; import com.rabbitmq.client.DeliverCallback;
import java.nio.charset.StandardCharsets;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
@@ -41,8 +40,7 @@ public class BrokerConnector {
System.out.println("Waiting for messages. To exit press CTRL+C"); System.out.println("Waiting for messages. To exit press CTRL+C");
DeliverCallback deliverCallback = (consumerTag, delivery) -> { DeliverCallback deliverCallback = (consumerTag, delivery) -> {
String message = new String(delivery.getBody(), StandardCharsets.UTF_8); // String message = new String(delivery.getBody(), StandardCharsets.UTF_8);
// System.out.println("Received: " + message);
channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false); channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
}; };