univer-6th-semester/nets
Code Actions Releases 3

Вывод сообщения о том, что очередь не принимает сообщения

Browse Source
This commit is contained in:
Артём Тищенко
2025-04-15 22:04:03 +03:00
parent def391aba9
commit 2089284c26
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
lab3/producer/app/src/main/java/dev/tishenko/producer/Send.java
View File

@@ -20,12 +20,17 @@ public class Send {
try (Connection connection = factory.newConnection(); try (Connection connection = factory.newConnection();
Channel channel = connection.createChannel()) { Channel channel = connection.createChannel()) {
channel.queueDeclarePassive(QUEUE_NAME); channel.queueDeclarePassive(QUEUE_NAME);
channel.confirmSelect();
int count = 0; int count = 0;
while (true) { while (true) {
String message = "Message from " + name + " #" + count++; String message = "Message from " + name + " #" + count++;
channel.basicPublish("", QUEUE_NAME, null, message.getBytes()); 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); Thread.sleep(delay);
} }
} }