diff --git a/lab3/producer/app/src/main/java/dev/tishenko/producer/Send.java b/lab3/producer/app/src/main/java/dev/tishenko/producer/Send.java index a321444..edb2ef6 100644 --- a/lab3/producer/app/src/main/java/dev/tishenko/producer/Send.java +++ b/lab3/producer/app/src/main/java/dev/tishenko/producer/Send.java @@ -20,12 +20,17 @@ public class Send { try (Connection connection = factory.newConnection(); Channel channel = connection.createChannel()) { channel.queueDeclarePassive(QUEUE_NAME); + channel.confirmSelect(); int count = 0; while (true) { String message = "Message from " + name + " #" + count++; channel.basicPublish("", QUEUE_NAME, null, message.getBytes()); - System.out.println(" [x] Sent '" + message + "'"); + if (!channel.waitForConfirms()) { + System.out.println(" [!] Message was NOT confirmed!"); + } else { + System.out.println(" [x] Sent '" + message + "'"); + } Thread.sleep(delay); } }