diff --git a/java/Recv.java b/java/Recv.java index 509823b..da85a77 100644 --- a/java/Recv.java +++ b/java/Recv.java @@ -17,7 +17,7 @@ public class Recv { System.out.println(" [*] Waiting for messages. To exit press CTRL+C"); DeliverCallback deliverCallback = (consumerTag, delivery) -> { - String message = new String(delivery.getBody(), "UTF-8"); + String message = new String(delivery.getBody(), StandardCharsets.UTF_8); System.out.println(" [x] Received '" + message + "'"); }; channel.basicConsume(QUEUE_NAME, true, deliverCallback, consumerTag -> { });