From d6ded3fca23ada4a74a3a0e72646ff345f7f708d Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Mon, 17 Mar 2025 16:22:15 -0400 Subject: [PATCH] Fix `RabbitAmqpAdmin.purgeQueue` for proper return The `Management.queuePurge()` now returns a `PurgeStatus` abstraction, where the `messageCount` property is what we expect on the `AmqpAdmin` contract. Related to: https://github.com/rabbitmq/rabbitmq-amqp-java-client/issues/151 --- .../springframework/amqp/rabbitmq/client/RabbitAmqpAdmin.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/spring-rabbitmq-client/src/main/java/org/springframework/amqp/rabbitmq/client/RabbitAmqpAdmin.java b/spring-rabbitmq-client/src/main/java/org/springframework/amqp/rabbitmq/client/RabbitAmqpAdmin.java index 0f932112..21c934b7 100644 --- a/spring-rabbitmq-client/src/main/java/org/springframework/amqp/rabbitmq/client/RabbitAmqpAdmin.java +++ b/spring-rabbitmq-client/src/main/java/org/springframework/amqp/rabbitmq/client/RabbitAmqpAdmin.java @@ -402,9 +402,8 @@ public class RabbitAmqpAdmin @ManagedOperation(description = "Purge a queue and return the number of messages purged") public int purgeQueue(String queueName) { try (Management management = getManagement()) { - management.queuePurge(queueName); + return (int) management.queuePurge(queueName).messageCount(); } - return 0; } @Override